Inital commit

Author: shyim

.gitignore

@@ -0,0 +1 @@
+node_modules

example/product-integration.js

@@ -0,0 +1,22 @@
+import {createFromIntegration} from '../src/index.js';
+import Criteria from '../src/data/criteria.data.js';
+
+async function test()
+{
+    let api = await createFromIntegration('<url>', 'SWIAD0VBY1HTR2PSTM5OAUVHMQ', 'eXcxZUlDWW5IZG1GRk5iM1MwUnRjb2cwN0dBcjFOQ2lySlUwYXk', 1);
+    
+    let repository = api.create('product');
+    let criteria = new Criteria();
+    criteria.addFilter(Criteria.equals('parentId', null));
+
+    let products = await repository.search(criteria, api.defaultContext());
+
+    const product = products[0];
+    console.log(product.name);
+    product.name = 'Node Test';
+    console.log(product.name);
+
+    await repository.save(products[0], api.defaultContext());
+} 
+
+test();

example/product-password.js

@@ -0,0 +1,22 @@
+import {createFromPasswordAndLogin} from '../src/index.js';
+import Criteria from '../src/data/criteria.data.js';
+
+async function test()
+{
+    let api = await createFromPasswordAndLogin('<url>', 'demo', 'demo', 1);
+    
+    let repository = api.create('product');
+    let criteria = new Criteria();
+    criteria.addFilter(Criteria.equals('parentId', null));
+
+    let products = await repository.search(criteria, api.defaultContext());
+
+    const product = products[0];
+    console.log(product.name);
+    product.name = 'Node Test';
+    console.log(product.name);
+
+    await repository.save(products[0], api.defaultContext());
+} 
+
+test();

package-lock.json

@@ -0,0 +1,29 @@
+{
+  "name": "shopware-admin-api",
+  "version": "0.1.0",
+  "description": "Shopware API",
+  "main": "index.js",
+  "type": "module",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/shyim/shopware-admin-api-node.git"
+  },
+  "keywords": [
+    "Shopware",
+    "Admin-API"
+  ],
+  "author": "Shyim",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/shyim/shopware-admin-api-node/issues"
+  },
+  "homepage": "https://github.com/shyim/shopware-admin-api-node#readme",
+  "dependencies": {
+    "axios": "^0.19.2",
+    "lodash": "^4.17.15",
+    "uuid": "^8.1.0"
+  }
+}

package.json

@@ -0,0 +1,62 @@
+import {createClient} from './client.js';
+import EntityDefinition from './factory/entity-definition.factory.js';
+import EntityHydrator from './data/entity-hydrator.data.js';
+import ChangesetGenerator from './data/changeset-generator.data.js';
+import EntityFactory from './data/entity-factory.data.js';
+import Repository from './data/repository.data.js';
+
+export default class Api {
+    constructor(url, token, version) {
+        this.url = url;
+        this.client = createClient(url, token, version)
+        this.version = version;
+    }
+
+    async _initialize() {
+        let schema = await this.client.get('_info/entity-schema.json');
+
+        this.EntityDefinition = EntityDefinition;
+        
+        Object.keys(schema.data).forEach((entityName) => {
+            this.EntityDefinition.add(entityName, schema.data[entityName]);
+        });
+
+        const hydrator = new EntityHydrator(this.EntityDefinition);
+        const changesetGenerator = new ChangesetGenerator(this.EntityDefinition);
+        const entityFactory = new EntityFactory();
+
+        this.create = (entityName, route, options) => {
+            if (!route) {
+                route = `/${entityName.replace(/_/g, '-')}`;
+            }
+            options = options || {};
+
+            if (options.version === undefined) {
+                options.version = this.version;
+            }
+
+            const definition = this.EntityDefinition.get(entityName);
+
+            return new Repository(
+                route,
+                definition.entity,
+                this.client,
+                hydrator,
+                changesetGenerator,
+                entityFactory,
+                options
+            );
+        };
+    }
+
+    defaultContext() {
+        return {
+            apiPath: `${this.url}/api`,
+            apiResourcePath: `${this.url}/api/v${this.version}`,
+            apiVersion: this.version,
+            authToken: {
+                access: this.client.token.access_token
+            }
+        }
+    }
+}

src/api.js

@@ -0,0 +1,54 @@
+import RefreshTokenHelper from './utils/refresh-token.helper.js';
+import axios from 'axios';
+
+export function createClient(url, token, version) {
+    const client = axios.create({
+        baseURL: `${url}/api/v${version}`
+    })
+
+    client.defaultUrl = url;
+    client.token = token;
+
+    client.defaults.headers.Authorization = `Bearer ${token.access_token}`;
+
+    refreshTokenInterceptor(client);
+
+    return client;
+}
+
+function refreshTokenInterceptor(client) {
+    const tokenHandler = new RefreshTokenHelper(client);
+
+    client.interceptors.response.use((response) => {
+        return response;
+    }, (error) => {
+        const { config, response: { status } } = error;
+        const originalRequest = config;
+        const resource = originalRequest.url.replace(originalRequest.baseURL, '');
+
+        if (tokenHandler.whitelist.includes(resource)) {
+            return Promise.reject(error);
+        }
+
+        if (status === 401) {
+            if (!tokenHandler.isRefreshing) {
+                tokenHandler.fireRefreshTokenRequest().catch(() => {
+                    return Promise.reject(error);
+                });
+            }
+
+            return new Promise((resolve, reject) => {
+                tokenHandler.subscribe((newToken) => {
+                    // replace the expired token and retry
+                    originalRequest.headers.Authorization = `Bearer ${newToken}`;
+                    originalRequest.url = originalRequest.url.replace(originalRequest.baseURL, '');
+                    resolve(Axios(originalRequest));
+                }, (err) => {
+                    reject(err);
+                });
+            });
+        }
+
+        return Promise.reject(error);
+    });
+}