index.js

const cwd = process.cwd();

require('@babel/register')({
  extensions: ['.js'],
  "presets": [
    "@babel/preset-env",
    "@babel/preset-react"
  ],
  "plugins": [
    "transform-es2015-modules-commonjs",
    "@babel/plugin-proposal-class-properties"
  ],

  // ignore: [function (filename) {

  //   return filename.indexOf(cwd + `/node_modules/`) === 0;
  // }],
});

require("@babel/polyfill");

const chalk = require("chalk");

const CoreModule = require("./modules").default;
const coreModule = new CoreModule({
});
const resolvers = coreModule.getResolvers();

const imagesMiddleware = require("./middleware/ImageThumb");

const {
  default: ModxDB,
} = require("./modules/modx/db");

const FormData = require("form-data");


async function modxRequest(url, options, ctx) {

  // console.log(chalk.green("modxRequest url"), url, options);

  let {
    // rejectUnauthorized = false,
    headers = {},
    method = "POST",
    data,
    body,
    ...other
  } = options || {}

  let {
    request,
    response,
  } = ctx;

  // const siteUrl = process.env.siteUrl;

  const {
    headers: {
      modauth,
      cookie,
      // siteurl: siteUrl,
      token,
    },
  } = request;


  data = {
    cache: false,
    format: "json",
    ...data
  }



  const siteUrl = process.env.siteUrl;

  if (!siteUrl) {
    throw new Error("siteUrl environment required");
  }

  url = `${siteUrl}${url}`;

  // body = JSON.stringify(data);


  body = body || new FormData();

  if (data) {


    for (var field in data) {
      let value = data[field];

      console.log(chalk.green("signin field value"), field, value);

      if (typeof value === "undefined") {
        continue;
      }
      else if (typeof value === "boolean") {
        value = value === true ? 1 : 0;
      }
      else if (typeof value === "object") {

        for (var i in value) {


          let f = `${field}[${i}]`;
          let v = value[i];

          if (typeof v === "boolean") {
            v = v === true ? 1 : 0;
          }


          body.append(f, v);

        }

        continue;
      }
      else {

      }

      body.append(field, value);
    }


  }



  if (modauth) {
    body.append("HTTP_MODAUTH", modauth);
  }

  token && body.append("t", token);

  // console.log(chalk.green("Request cookie"), cookie);
  // console.log(chalk.green("Request headers"), headers);
  // console.log(chalk.green("Request body"), body);

  // return;

  return await fetch(url, {
    credentials: 'same-origin',
    timeout: 15000,
    method,
    headers: {
      ...headers,
      cookie,
    },
    body,
    ...options,
  })
    .catch(error => {
      // this.error(error);
      throw (error);
    });

}


let getCurrentUser = async function (ctx) {
  //

  let currentUser;

  const {
    request,
    modx,
  } = ctx;

  if (!request) {
    return null;
  }

  // console.log(chalk.green("getCurrentUser headers"), request.headers);
  // console.log(chalk.green("getCurrentUser ctx"), ctx.knex);

  const {
    headers: {
      cookie,
    },
  } = request;

  let PHPSESSID;


  cookie && cookie.split(";").map(n => {

    let {
      0: name,
      1: value,
    } = n.split("=");

    if (name && name.trim() === "PHPSESSID") {

      // console.log(chalk.green("getCurrentUser headers PHPSESSID"), `'${value}'`);

      PHPSESSID = value && value.trim() || null;


    }

  })


  /**
   * Если был получен кукис, пытаемся получить сессию из базы
   */
  if (PHPSESSID) {

    currentUser = await modx.query.userBySession(null, {
      PHPSESSID,
    }, ctx);

    // console.log(chalk.green("getCurrentUser headers user"), currentUser);


  }

  return currentUser;

}


switch (process.env.action) {

  case "build-schema":

    require("./schema").default(process.env.schemaType);

    break;

  case "start-server":

    const startServer = require("@prisma-cms/server").default;

    //

    const {
      MYSQL_HOST = "localhost",
      MYSQL_USER = "root",
      MYSQL_PASSWORD = "",
      MYSQL_DB,
      MYSQL_TABLE_PREFIX = "modx_",
    } = process.env;


    if (!MYSQL_DB) {
      throw new Error("Environment MYSQL_DB required");
    }


    startServer({
      typeDefs: 'src/schema/generated/api.graphql',
      resolvers,
      imagesMiddleware,
      contextOptions: {
        db: null,
        getCurrentUser,
        modx: new ModxDB({
          tablePrefix: MYSQL_TABLE_PREFIX,
        }),
        modxRequest,
      },
      Mailer: null,
      knexOptions: {
        connection: {
          host: MYSQL_HOST,
          user: MYSQL_USER,
          database: MYSQL_DB,
          password: MYSQL_PASSWORD,
        },
      },
    });

    break;

  // default: throw (new Error("action env not defined"))

}