server.js

const fs = require("fs");
const express = require("express");
const cors = require("cors");
const sqlite3 = require("sqlite3").verbose();
const http = require("http");
const { graphqlHTTP } = require("express-graphql");
const { buildSchema } = require("graphql");

const schema = buildSchema(`
  type Product {
    id: Float
    bodyHtml: String
    image: String
  }

  type Query {
    products: [Product]
  }
`);

const root = {
  products: async () => {
    return new Promise((resolve, reject) => {
      const db = new sqlite3.Database("mydatabase.db");
      db.all("SELECT * FROM products", (err, rows) => {
        if (err) {
          reject(err);
        } else {
          resolve(rows);
        }
      });
      db.close();
    });
  },
};

const app = express();

const corsOptions = {
  origin: "*",
  credentials: true,
  optionSuccessStatus: 200,
  methods: "GET,HEAD,OPTIONS,PUT,PATCH,POST,DELETE",
  allowedHeaders: ["Content-Type", "Access-Control-Allow-Origin"],
};

app.use(cors(corsOptions));

const server = http.createServer(app);
const io = require("socket.io")(server, {
  cors: {
    origin: "http://localhost:5173",
    credentials: true,
    methods: "GET,HEAD,OPTIONS,PUT,PATCH,POST,DELETE",
    allowedHeaders: ["Content-Type", "Access-Control-Allow-Origin"],
  },
});
const port = 3001;

app.use(express.json());

app.use(
  "/graphql",
  graphqlHTTP({
    schema: schema,
    rootValue: root,
    graphiql: true,
  })
);

const query = `
  query {
    products(first: 10) {
        nodes {
          id
          bodyHtml
          images(first: 1) {
              nodes {
                src
              }
          }
        }
    }
  }
`;

async function fetchDataFromAPI() {
  try {
    const shopifyUrl = "https://cpb-new-developer.myshopify.com/";
    const accessToken = "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";

    const response = await fetch(
      `${shopifyUrl}/admin/api/2024-01/graphql.json`,
      {
        method: "POST",
        headers: {
          "X-Shopify-Access-Token": accessToken,
          "Content-Type": "application/json",
        },
        body: JSON.stringify({ query }),
      }
    );

    if (response.ok) {
      const { data } = await response.json();

      const dbFile = "mydatabase.db";
      const dbFileExists = fs.existsSync(dbFile);

      if (!dbFileExists) {
        const db = new sqlite3.Database(dbFile);
        db.run(`CREATE TABLE IF NOT EXISTS products (
            id INTEGER PRIMARY KEY,
            bodyHtml TEXT,
            image TEXT
          )`);
        db.close();
      }

      const db = new sqlite3.Database(dbFile);
      for (const product of data.products.nodes) {
        const { id, bodyHtml, images } = product;
        const query =
          "INSERT OR REPLACE INTO products (id, bodyHtml, image) VALUES (?, ?, ?)";
        const params = [id.replace(/\D/g, ''), bodyHtml, images.nodes[0].src];
        
        db.run(query, params);
      }
      db.close();

      io.on("connection", (socket) => {
        io.emit("databaseUpdated", {
          message: "START",
        });
        socket.on("disconnect", () => {
          console.log("user disconnected");
        });
      });
    } else {
      console.error("Request failed with status", response.status);
    }
  } catch (error) {
    console.error("Request error:", error);
  }
}

server.listen(port, async () => {
  console.log(`Server started on port ${port}`);
  await fetchDataFromAPI();
});