Adds a draft of "fromTraffic"

.vscode/settings.json

@@ -0,0 +1,8 @@
+{
+  "json.schemas": [
+    {
+      "fileMatch": ["test/oas/fixtures/*.json"],
+      "url": "https://raw.githubusercontent.com/OAI/OpenAPI-Specification/f1adc846131b33be72df6a0c87e5e5da59dde0ff/schemas/v3.0/schema.json"
+    }
+  ]
+}

PREREQUISITES.md

@@ -0,0 +1 @@
+- [ ] Export `cleanUrl` function from MSW.

README.md

@@ -1,25 +1,47 @@
-# Library name
+# `@mswjs/source`
 
-> A short description about what your library is.
+## Install
 
-## Motivation
+```sh
+$ npm install @mswjs/source -D
+# or
+$ yarn add @mswjs/source -D
+```
+
+## Sources
+
+### Browser traffic (HAR)
 
-> Elaborate on the reason behind this library: why may people need it? What issues does it solve? How is it different from the similar libraries?
+```js
+import { fromTraffic } from '@mswjs/source'
+import traffic from './github.com.har'
 
-## Getting started
+export const handlers = fromTraffic(traffic)
+```
+
+### Test runtime
 
-> Go through the steps necessary to install, configure, and use your library.
+```js
+// jest.setup.js
+import { setupServer } from 'msw/node'
+import { fromRuntime } from '@mswjs/source'
 
-### Install
+const server = setupServer()
 
-```bash
-$ npm install <LIBRARY_NAME>
+beforeAll(() => {
+  server.listen()
+  fromRuntime(server)
+})
 ```
 
-## Documentation
+### OpenAPI (Swagger)
 
-> Reference the documentation website, or write the documentation straight in this README file.
+- Explain what spec properties are used as mocked responses.
 
-## Contributing
+```js
+import { fromOpenApi } from '@mswjs/source'
+import apiDocument from 'api.spec.json'
 
-Please read the [Contribution guidelines](CONTRIBUTING.md) to start with your awesome contributions!
+const apiDocument = fs.readFileSync('spec.json')
+export const handlers = fromOpenApi(apiDocument)
+```

package.json

@@ -14,7 +14,6 @@
     "clean": "rimraf ./lib",
     "build": "yarn lint && yarn clean && rollup -c rollup.config.ts",
     "test": "jest test",
-    "test:lib": "jest STANDARDS.ts --testRegex=\"(STANDARDS\\.ts)\"",
     "prepublishOnly": "yarn build && yarn test:lib && yarn test"
   },
   "files": [
@@ -53,7 +52,7 @@
     "husky": "^4.3.8",
     "jest": "^26.6.3",
     "lint-staged": "^10.5.3",
-    "msw": "^0.26.2",
+    "msw": "^0.34.0",
     "prettier": "^2.2.1",
     "rimraf": "^3.0.2",
     "rollup": "^2.38.4",
@@ -64,6 +63,8 @@
   },
   "dependencies": {
     "@apidevtools/swagger-parser": "^10.0.2",
-    "openapi-types": "^7.2.3"
+    "@types/har-format": "^1.2.7",
+    "openapi-types": "^7.2.3",
+    "outvariant": "^1.2.0"
   }
 }

src/index.ts

@@ -1 +1 @@
-export { fromOpenAPI } from './oas/fromOpenAPI'
+export { fromOpenApi } from './oas/fromOpenApi'

src/oas/fromOpenAPI.ts

@@ -1,27 +1,32 @@
-import { rest } from 'msw'
+import { RequestHandler, rest } from 'msw'
 import { OpenAPIV3, OpenAPIV2 } from 'openapi-types'
-import { parse } from '@apidevtools/swagger-parser'
+import * as SwaggerParser from '@apidevtools/swagger-parser'
 
-export async function fromOpenAPI(
+const parser = new SwaggerParser()
+
+/**
+ * Generates request handlers fro the given OpenAPI document.
+ */
+export async function fromOpenApi(
   document: string | OpenAPIV3.Document | OpenAPIV2.Document,
-) {
-  const api = await parse(document)
+): Promise<RequestHandler[]> {
+  const api = await parser.dereference(document)
 
-  const handlers = Object.entries(api.paths).reduce<any>(
+  const handlers = Object.entries(api.paths).reduce<RequestHandler[]>(
     (handlers, [url, pathDef]) => {
       const nextHandlers = Object.entries(pathDef).map(
         ([method, def]: [string, any]) => {
           if (!(method in rest)) {
             return
           }
 
-          // @ts-expect-error tbd
+          // @ts-expect-error TBD
           const resolvedUrl = api.basePath
-            ? // @ts-expect-error tbd
+            ? // @ts-expect-error TBD
               new URL(url, api.basePath).toString()
             : url
 
-          // @ts-expect-error tbd
+          // @ts-expect-error TBD
           return rest[method](resolvedUrl, (req, res, ctx) => {
             const status = req.url.searchParams.get('response') || '200'
             const response = def.responses[status]