BTW here is my server code, which I made based on the main app building tutorial (https://developers.shopify.com/tutorials/build-a-shopify-app-with-node-and-react/listen-for-store-ev...)
require('isomorphic-fetch');
const dotenv = require('dotenv');
const Koa = require('koa');
const next = require('next');
const { default: createShopifyAuth } = require('@shopify/koa-shopify-auth');
const { verifyRequest } = require('@shopify/koa-shopify-auth');
const session = require('koa-session');
//webhooks
const Router = require('koa-router')
const {receiveWebhook, registerWebhook} = require('@shopify/koa-shopify-webhooks');
dotenv.config();
const { default: graphQLProxy } = require('@shopify/koa-shopify-graphql-proxy');
const { ApiVersion } = require('@shopify/koa-shopify-graphql-proxy');
const port = parseInt(process.env.PORT, 10) || 3000;
const dev = process.env.NODE_ENV !== 'production';
const app = next({ dev });
const handle = app.getRequestHandler();
const { SHOPIFY_API_SECRET_KEY, SHOPIFY_API_KEY } = process.env;
app.prepare().then(() => {
const server = new Koa();
server.use(session(server));
server.keys = [SHOPIFY_API_SECRET_KEY];
//webhooks
const router = new Router();
server.use(
createShopifyAuth({
apiKey: SHOPIFY_API_KEY,
secret: SHOPIFY_API_SECRET_KEY,
scopes: ['read_products', 'write_products', 'read_orders', 'write_orders'],
async afterAuth(ctx) {
//console.log(`-- ctx.method: ${ctx.method} \n-- ctx.url: ${ctx.url} --`);
const { shop, accessToken } = ctx.session;
ctx.cookies.set('shopOrigin', shop, { httpOnly: false });
//webhooks
const wh_orders_create = await registerWebhook({
address: 'https://<shop>.myshopify.com/webhooks/orders/create',
topic: 'ORDERS_CREATE',
accessToken,
shop,
});
if (wh_orders_create.success) {
console.log('Successfully registered createOrderWebhook webhook!');
} else {
console.log(
'Failed to register createOrderWebhook webhook',
wh_orders_create.result,
);
console.log(
'userErrors',
wh_orders_create.result.data.webhookSubscriptionCreate.userErrors
);
}
const wh_products_create = await registerWebhook({
address: 'https://<shop>.myshopify.com/webhooks/products/create',
topic: 'PRODUCTS_CREATE',
accessToken,
shop,
});
if (wh_products_create.success) {
console.log('Successfully registered createOrderWebhook webhook!');
} else {
console.log(
'Failed to register createOrderWebhook webhook',
wh_products_create.result,
);
console.log(
'userErrors',
wh_products_create.result.data.webhookSubscriptionCreate.userErrors
);
}
ctx.redirect('/');
},
}),
);
server.use(verifyRequest());
server.use(async (ctx) => {
await handle(ctx.req, ctx.res);
ctx.respond = false;
ctx.res.statusCode = 200;
return
});
server.use(
// receive webhooks
receiveWebhook({
path: '/webhooks/orders/create',
secret: SHOPIFY_API_SECRET_KEY,
onReceived(ctx) {
console.log('received webhook: ', ctx.state.webhook);
},
}),
);
server.use(
// receive webhooks
receiveWebhook({
path: '/webhooks/products/create',
secret: SHOPIFY_API_SECRET_KEY,
onReceived(ctx) {
console.log('received webhook: ', ctx.state.webhook);
},
}),
);
server.use(graphQLProxy({version: ApiVersion.July19}));
server.listen(port, () => {
console.log(`> Ready on http://localhost:${port}`);
});
});Should I perhaps be trying another approach?
