ヘッドレスコマース型の小売ストアをCommercetools と統合する方法 – Part 1

const {
  ClientBuilder,
  createAuthForClientCredentialsFlow,
  createHttpClient,
} = require('@commercetools/sdk-client-v2')
const { createApiBuilderFromCtpClient } = require('@commercetools/platform-sdk')
const fetch = require('node-fetch')

const HTTP_OK = 200;

const projectKey = 'YOUR_PROJECT_KEY';

const authMiddlewareOptions = {
  host: 'https://auth.eu-central-1.aws.commercetools.com',
  projectKey,
  credentials: {
    clientId: 'API_CLIENT_ID',
    clientSecret: 'API_CLIENT_SECRET',
  },
  scopes: ['API_CLIENT_SCOPES'],
  fetch,
}

const httpMiddlewareOptions = {
  host: 'https://api.eu-central-1.aws.commercetools.com/',
  fetch,
}

const client = new ClientBuilder()
  .withProjectKey(projectKey)
  .withMiddleware(createAuthForClientCredentialsFlow(authMiddlewareOptions))
  .withMiddleware(createHttpClient(httpMiddlewareOptions))
  .withUserAgentMiddleware()
  .build()

const apiRoot = createApiBuilderFromCtpClient(client)

export module ctClient {

  export async function getOrders() {
    let result: any[] = [];
    await apiRoot
      .withProjectKey({ projectKey })
      .orders()
      .get()
      .execute()
      .then((res: any) => {
        if (res.statusCode == HTTP_OK) {
          result = res.body.results;    
        }
      })
    return result;
  }

  export async function getOrdersById(orderId: string) {
    let result: any[] = [];
    await apiRoot
      .withProjectKey({ projectKey })
      .orders()
      .withOrderNumber(orderId)
      .get()
      .execute()
      .then((res: any) => {
        if (res.statusCode == HTTP_OK) {
          result = res.body.results;    
        }
      })
    return result;
  }

  export async function getOrdersByUsername(userName: string) {
    let result: any[] = [];
    await apiRoot
      .withProjectKey({ projectKey })
      .orders()
      .search()
      .post({
        body: { query: '{ "filter": [ { "exact": {  "field": "createdBy.clientId", "value": ' + userName + ' } } ] }' }
      })
      .execute()
      .then((res: any) => {
        if (res.statusCode == HTTP_OK) {
          result = res.body.results;    
        }
      })
    return result;
  }

  export async function createOrder(order: string) {
    let result: any[] = [];
    await apiRoot
      .withProjectKey({ projectKey })
      .orders()
      .post({
        body: JSON.parse(order),
      })
      .execute()
      .then((res: any) => {
        if (res.statusCode == HTTP_OK) {
          result = res.body.results;    
        }
      })
    return result;
  }

  export async function updateOrder(orderId: string, orderUpdate: string) {
    let result: any[] = [];
    await apiRoot
      .withProjectKey({ projectKey })
      .orders()
      .withOrderNumber(orderId)
      .post({
        body: JSON.parse(orderUpdate),
      })
      .execute()
      .then((res: any) => {
        if (res.statusCode == HTTP_OK) {
          result = res.body.results;    
        }
      })
    return result;
  }
}

import * as bodyParser from "body-parser";
import * as express from "express";
import { Logger } from "../logger/logger";
import { ctClient } from "./commercetools-client";

class OrderRoutes {

    public express: express.Application;
    public logger: Logger;

    // array to hold users
    public orders: Order[];

    constructor() {
        this.express = express();
        this.middleware();
        this.routes();
        this.logger = new Logger();
    }

    // Configure Express middleware.
    private middleware(): void {
        this.express.use(bodyParser.json());
        this.express.use(bodyParser.urlencoded({ extended: false }));
    }

    private routes(): void {

        // request to get all the orders
        this.express.get("/all", async (req, res) => {
            this.logger.info("url:::::::" + req.url);
            let result = await ctClient.getOrders();
            res.json(this.prepareResponse(result));
        });

        // request to get an order by orderId
        this.express.get("/id/:orderId", async (req, res) => {
            this.logger.info("url:::::::" + req.url);
            let result = await ctClient.getOrdersById(req.params.orderId);
            res.json(this.prepareResponse(result));
        });

        // request to get all the orders by userName
        this.express.get("/username/:userName", async (req, res) => {
            this.logger.info("url:::::::" + req.url);
            let result = await ctClient.getOrdersByUsername(req.params.userName);
            res.json(this.prepareResponse(result));
        });

        // request to create the order
        this.express.post("/", async (req, res) => {
            this.logger.info("url:::::::" + req.url + ":::::::body::::::" + JSON.stringify(req.body));
            let result = await ctClient.createOrder(this.prepareCreateRequest(JSON.stringify(req.body)));
            res.json(this.prepareResponse(result));
        });

        // request to create the order
        this.express.options("/", async (req, res) => {
            this.logger.info("url:::::::" + req.url + ":::::::body::::::" + JSON.stringify(req.body));
            let result = await ctClient.createOrder(this.prepareCreateRequest(JSON.stringify(req.body)));
            res.json(this.prepareResponse(result));
        });

        // request to update the order
        this.express.put("/id/:orderId", async (req, res) => {
            this.logger.info("url:::::::" + req.url + ":::::::body::::::" + JSON.stringify(req.body));
            let result = await ctClient.updateOrder(req.params.orderId, this.prepareUpdateRequest(req.body));
            res.json(this.prepareResponse(result));
        });

        // request to update the order
        this.express.options("/id/:orderId", async (req, res) => {
            this.logger.info("url:::::::" + req.url + ":::::::body::::::" + JSON.stringify(req.body));
            let result = await ctClient.updateOrder(req.params.orderId, this.prepareUpdateRequest(req.body));
            res.json(this.prepareResponse(result));
        });
    }
    
    // OMITS: request and response adapter methods
    [...]
}
export default new Order().express;