LooseTerrifyingSpaceMonkey/.env Secret

## .env
SHOP=super-test-api.myshopify.com          # Your test store URL
API_KEY=                                   # Your API key
API_SECRET_KEY=                            # Your API secret key
SCOPES=read_products,write_products        # Your app's required scopes
HOST=                                      # Your app's host, without the protocol prefix (in this case we used an `ngrok` tunnel to provide a secure connection to our localhost)
HOST_SCHEME=https                          # Either http or https. Note http is intended for local development with localhost.

## shopify-api.js
const express = require('express');
const app = express();
const http = require('http');
const {randomInt} = require("crypto");
const {DataType} = require("@shopify/shopify-api");
const Shopify = require('@shopify/shopify-api').Shopify;
const ApiVersion = require('@shopify/shopify-api').ApiVersion;
require('dotenv').config();

const { API_KEY, API_SECRET_KEY, SCOPES, SHOP, HOST, HOST_SCHEME } = process.env;

Shopify.Context.initialize({
    API_KEY,
    API_SECRET_KEY,
    SCOPES: [SCOPES],
    HOST_NAME: HOST.replace(/https?:\/\//, ""),
    HOST_SCHEME,
    IS_EMBEDDED_APP: false,
    API_VERSION: ApiVersion.July22
});

const ACTIVE_SHOPIFY_SHOPS = {};

app.get('/', async (http_request, http_response) => {
    if(ACTIVE_SHOPIFY_SHOPS[SHOP] === undefined) {
        http_response.redirect('/auth/shopify');
    } else {
        http_response.send('<html><body><p>Your Node instance is running.</p></body></html>');
    }
});

app.get('/auth/shopify', async (http_request, http_response) => {
    let authorizedRoute = await Shopify.Auth.beginAuth(
        http_request,
        http_response,
        SHOP,
        '/auth/shopify/callback',
        false,
    );
    return http_response.redirect(authorizedRoute);
});

app.get('/auth/shopify/callback', async (http_request, http_response) => {
    try {
        const client_session = await Shopify.Auth.validateAuthCallback(
            http_request,
            http_response,
            http_request.query);
        ACTIVE_SHOPIFY_SHOPS[SHOP] = client_session.scope;
        console.log(client_session.accessToken);
    } catch (eek) {
        console.error(eek);
        http_response.send('<html><body><p>${JSON.stringify(eek)}</p></body></html>')
    }
    return http_response.redirect('/auth/shopify/success');
});

app.get('/auth/shopify/success', async  (http_request, http_response) => {
    http_response.send('<html><body><p>You have successfully authenticated and are back at your app.</p><p><a href="/products">View Products</a></p></body></html>');
});

app.get('/products', async (http_request, http_response) => {
    const client_session = await Shopify.Utils.loadCurrentSession(http_request, http_response);
    console.log('client_session: ' + JSON.stringify(client_session));

    const client = new Shopify.Clients.Rest(client_session.shop, client_session.accessToken);

    const products = await client.get({
        path: 'products'
    });
    console.log('Products: ' + JSON.stringify(products));

    let product_names_formatted = '';
    for(let i =0; i < products.body.products.length; i++) {
       product_names_formatted += '<p>' + products.body.products[i].title + '</p>';
    }

    http_response.send(`<html><body><p>Products List</p>
          ${product_names_formatted}
          <p><form action="/products/add" method="post"> <button>Add Product</button>
          </form></p>
          </body></html>`);

});

app.post('/products/add', async (http_request, http_response) => {
    const client_session = await Shopify.Utils.loadCurrentSession(http_request, http_response);

    const client = new Shopify.Clients.Rest(client_session.shop, client_session.accessToken);

    const payload = {
        product: {
            title: "T-shirt with witty saying " + randomInt(1, 500),
            vendor: "Best T-shirts Evah",
            product_type: "Clothing",
            tags: ["T-shirt", "Funny", "Geeky"],
            body_html: "<strong>Binary jokes</strong>",
            published: false
        }
    };

    await client.post({
        path: 'products',
        data: payload,
        type: DataType.JSON
    });

    http_response.redirect('/products');
});

const httpServer = http.createServer(app);

httpServer.listen(3000, () => console.log('Your Slack-OAuth app is listening on port 3000.'));
	SHOP=super-test-api.myshopify.com # Your test store URL
	API_KEY= # Your API key
	API_SECRET_KEY= # Your API secret key
	SCOPES=read_products,write_products # Your app's required scopes
	HOST= # Your app's host, without the protocol prefix (in this case we used an `ngrok` tunnel to provide a secure connection to our localhost)
	HOST_SCHEME=https # Either http or https. Note http is intended for local development with localhost.
	const express = require('express');
	const app = express();
	const http = require('http');
	const {randomInt} = require("crypto");
	const {DataType} = require("@shopify/shopify-api");
	const Shopify = require('@shopify/shopify-api').Shopify;
	const ApiVersion = require('@shopify/shopify-api').ApiVersion;
	require('dotenv').config();

	const { API_KEY, API_SECRET_KEY, SCOPES, SHOP, HOST, HOST_SCHEME } = process.env;

	Shopify.Context.initialize({
	API_KEY,
	API_SECRET_KEY,
	SCOPES: [SCOPES],
	HOST_NAME: HOST.replace(/https?:\/\//, ""),
	HOST_SCHEME,
	IS_EMBEDDED_APP: false,
	API_VERSION: ApiVersion.July22
	});

	const ACTIVE_SHOPIFY_SHOPS = {};

	app.get('/', async (http_request, http_response) => {
	if(ACTIVE_SHOPIFY_SHOPS[SHOP] === undefined) {
	http_response.redirect('/auth/shopify');
	} else {
	http_response.send('<html><body><p>Your Node instance is running.</p></body></html>');
	}
	});

	app.get('/auth/shopify', async (http_request, http_response) => {
	let authorizedRoute = await Shopify.Auth.beginAuth(
	http_request,
	http_response,
	SHOP,
	'/auth/shopify/callback',
	false,
	);
	return http_response.redirect(authorizedRoute);
	});

	app.get('/auth/shopify/callback', async (http_request, http_response) => {
	try {
	const client_session = await Shopify.Auth.validateAuthCallback(
	http_request,
	http_response,
	http_request.query);
	ACTIVE_SHOPIFY_SHOPS[SHOP] = client_session.scope;
	console.log(client_session.accessToken);
	} catch (eek) {
	console.error(eek);
	http_response.send('<html><body><p>${JSON.stringify(eek)}</p></body></html>')
	}
	return http_response.redirect('/auth/shopify/success');
	});

	app.get('/auth/shopify/success', async (http_request, http_response) => {
	http_response.send('<html><body><p>You have successfully authenticated and are back at your app.</p><p><a href="/products">View Products</a></p></body></html>');
	});

	app.get('/products', async (http_request, http_response) => {
	const client_session = await Shopify.Utils.loadCurrentSession(http_request, http_response);
	console.log('client_session: ' + JSON.stringify(client_session));

	const client = new Shopify.Clients.Rest(client_session.shop, client_session.accessToken);

	const products = await client.get({
	path: 'products'
	});
	console.log('Products: ' + JSON.stringify(products));

	let product_names_formatted = '';
	for(let i =0; i < products.body.products.length; i++) {
	product_names_formatted += '<p>' + products.body.products[i].title + '</p>';
	}

	http_response.send(`<html><body><p>Products List</p>
	${product_names_formatted}
	<p><form action="/products/add" method="post"> <button>Add Product</button>
	</form></p>
	</body></html>`);

	});

	app.post('/products/add', async (http_request, http_response) => {
	const client_session = await Shopify.Utils.loadCurrentSession(http_request, http_response);

	const client = new Shopify.Clients.Rest(client_session.shop, client_session.accessToken);

	const payload = {
	product: {
	title: "T-shirt with witty saying " + randomInt(1, 500),
	vendor: "Best T-shirts Evah",
	product_type: "Clothing",
	tags: ["T-shirt", "Funny", "Geeky"],
	body_html: "<strong>Binary jokes</strong>",
	published: false
	}
	};

	await client.post({
	path: 'products',
	data: payload,
	type: DataType.JSON
	});

	http_response.redirect('/products');
	});

	const httpServer = http.createServer(app);

	httpServer.listen(3000, () => console.log('Your Slack-OAuth app is listening on port 3000.'));