index.js

const express = require('express')
const bodyParser = require('body-parser')
const fetch = require('node-fetch');
const app = express();
const {draw, getIPFSFile} = require('./src/render_svg');
const {ethers} = require("ethers");
const {db, getTwitterUsers} = require("./src/twitter");

let port = process.env.PORT || 3000;
// let bearer = "AAAAAAAAAAAAAAAAAAAAAMGxPQEAAAAAn2J6b%2BvyI8t8qKryhfZUisZE94Q%3DcfOS71mRCVynHctv4q910Emh4Ezh0409XQHgjZ4UwDDciQhJ78";


let rooms = [
    {
        "type": "Deluxe Room",
        "price": 110.3,
        "frequency": "per night",
        // "discountPrice": "1",
        "image": "./hotel_3.jpg"
    },
    {
        "type": "King Suite",
        "price": 89.3,
        "frequency": "per night",
        // "discountPrice": "1.5",
        "image": "./hotel_2.png"
    },
    {
        "type": "Superior Deluxe Suite",
        "price": 55.1,
        "frequency": "per night",
        // "discountPrice": "4",
        "image": "./hotel_1.jpg"
    },
    {
        "type": "Super Econom",
        "price": 11,
        "frequency": "per night",
        // "discountPrice": "4",
        "members_only": 1,
        "image": "./hotel_4.jpg"
    }
];

function useTokens(initProducts, tokens){
    let hasDiscount = 0;
    let hasFreeShiping = 0;
    let showExtraProducts = 0;

    tokens.forEach(ticket=>{
        if (token.hasOwnProperty('ticketClass')) {
            switch (token.ticketClass) {
                case "0n":
                    hasDiscount++;
                    break;
                case "1n":
                    hasFreeShiping++;
                    break;
                case "2n":
                    showExtraProducts++;
                    break;
            }
        }
    })

    let activeRooms = [];
    initProducts.forEach(room=>{
        showExtraProducts && (room.members_only = 0);
        hasFreeShiping && (room.free_shipping = 1);
        hasDiscount && (room.discountPrice = parseFloat(room.price) - 2);

        room.members_only || activeRooms.push(room)
    });
    return activeRooms;
}

// Add headers
app.use(function (req, res, next) {

    // Website you wish to allow to connect
    // res.setHeader('Access-Control-Allow-Origin', 'http://localhost:8888');
    res.setHeader('Access-Control-Allow-Origin', '*');

    // Request methods you wish to allow
    res.setHeader('Access-Control-Allow-Methods', 'GET, POST');

    // Request headers you wish to allow
    res.setHeader('Access-Control-Allow-Headers', 'X-Requested-With,content-type');

    // Set to true if you need the website to include cookies in the requests sent
    // to the API (e.g. in case you use sessions)
    // res.setHeader('Access-Control-Allow-Credentials', true);

    // Pass to next layer of middleware
    next();
});

app.use(bodyParser.json() );       // to support JSON-encoded bodies
app.use(bodyParser.urlencoded({     // to support URL-encoded bodies
    extended: true
}));

app.get('/svgipfs/', async (request, response) => {
    try {
        {
            // test GET param contract
            if (!request.query || !request.query.ipfshash || !request.query.ipfshash.length){
                throw new Error("correct ipfshash required");
            }

            let ipfshashRe = /^[a-zA-Z0-9]{46}$/;
            let ipfshashTest = ipfshashRe.test(String(request.query.ipfshash));

            if (!ipfshashTest){
                throw new Error("wrong ipfshash");
            }
        }

        {
            // test GET param autograph
            if (!request.query || !request.query.autograph || !request.query.autograph.length){
                throw new Error("correct autograph required");
            }
        }

        let ipfsFileBuf = await getIPFSFile(request.query.ipfshash);

        let svg = await draw(ipfsFileBuf, request.query.autograph);


        // Express 4:
        response.status(200)
            .attachment(`autograph.svg`)
            .send(svg);

        // console.log(json);

        // response.json( json );
    } catch(err) {
        // console.log(err);
        response.json( {res: "request failed. "+err} );
    }
})

app.get('/svg/', async (request, response) => {
    let contractAddress = '',
        tokenId = '',
        autograph = '';
    try {
        {
            // test GET param contract
            if (!request.query || !request.query.contract || !request.query.contract.length){
                throw new Error("correct contract required");
            }

            contractAddress = request.query.contract;

            if (!/^0x[a-zA-Z0-9]{40}$/.test(String(contractAddress))){
                throw new Error("wrong contract");
            }
        }

        {
            // test GET param tokenId
            if (!request.query || !request.query.tokenId || !request.query.tokenId.length){
                throw new Error("correct tokenId required");
            }

            tokenId = request.query.tokenId;

            if (!/^[a-zA-Z0-9_]+$/.test(String(tokenId))){
                throw new Error("wrong tokenId format");
            }
        }

        {
            // test GET param autograph
            if (!request.query || !request.query.autograph || !request.query.autograph.length){
                throw new Error("correct autograph required");
            }
            autograph = request.query.autograph;
        }


        let provider = new ethers.providers.InfuraProvider("rinkeby", "a3babf9f8bf64e5ca6b4caa070169744");
        let tokenUriAbi = '[{"constant": true,"inputs":[{"name":"_tokenId","type":"uint256"}],"name":"tokenURI","outputs": [{"name": "url", "type": "string"}],"payable": false,"stateMutability": "view","type": "function"}]';

        // let stormbirdSART = "0xa567f5A165545Fa2639bBdA79991F105EADF8522";
        // let tokenID = "284";
        let contract = new ethers.Contract( contractAddress , tokenUriAbi , provider );

        let tokenMetaObj;
        try {
            console.log('request tokenMetaObj');
            tokenMetaObj = await contract.callStatic.tokenURI(tokenId);
            // console.log(tokenMetaObj);
        } catch(e){
            console.log(e);
            throw new Error(`cant fetch tokenURI for contract "${contractAddress}" and tokenID "${tokenId}"`);
        }

        console.log('fetch '+tokenMetaObj);
        let responce = await fetch(tokenMetaObj);
        let dataJson = await responce.json();

        if (dataJson && dataJson.image){
            console.log('request file');
            let responce = await fetch(dataJson.image);
            let imageData = await responce.buffer();
            console.log('draw svg');
            let svg = await draw(imageData, autograph);

            response.status(200)
                .attachment(`autograph.svg`)
                .send(svg);

        } else {
            response.json( {res: "cant generate image."} );
        }

    } catch(err) {
        // console.log(err);
        response.json( {res: "request failed. "+err} );
    }
})

app.get('/twitter/', async (request, response) => {

    let time = Date.now();

    let name;


    try {
        if (!request.query || !request.query.name || !request.query.name.length){
            throw new Error("please dont forget to send username");
        }
        name = request.query.name;

        if (!/^[a-zA-Z0-9_]{3,15}$/.test(String(name))){
            throw new Error("wrong username");
        }

        response.json( {data: await getTwitterUsers(name) });
        // console.log(getTwitterUsers(name));
        console.log('used time: ' + (Date.now() - time));

    } catch(err) {
        // console.log(err);
        response.json( {res: "request failed. "+err} );
    }
});
app.get('/twitter2/', async (request, response) => {
    const letters = 'ABCDEFGHIKLMNOPQRSTVXYZ_1234567890'.toLowerCase();
    // const letters = 'ABCDEFGHIKLMNOPQRSTQRSTVXYZ'.toLowerCase();
    // const letters = 'AB'.toLowerCase();
    let time;
    try {
        for (let i1 = 0; i1 < letters.length; i1++ ){
            for (let i2 = 0; i2 < letters.length; i2++ ){
                time = Date.now();
                let res = await getTwitterUsers(letters[i1] + letters[i2]);
                console.log('q =  ' + letters[i1] + letters[i2] +' ;used time: ' + (Date.now() - time));
            }
        }
        response.json({res:'all ok'});

    } catch(err) {
        // console.log(err);
        response.json( {res: "request failed. "+err} );
    }
});

app.get('/', (request, response) => {
// response.send('Service works with POST only.');
    // response.json(rooms);
    // const params = new URLSearchParams('foo=bar&foo=baz');
    // for (const name of params.keys()) {
    //     console.log(name);
    // }
    response.json(useTokens(rooms, []) );
});

app.post('/', function (request, response) {
    if (!request.body || !request.body.tickets || !request.body.tickets.length){
        response.json(rooms);
    } else {
        let tickets = JSON.parse(request.body.tickets);
        response.json(useTokens(rooms, tickets) );
    }
});

app.listen(port, (err) => {
    if (err) {
        return console.log('something bad happened', err)
    }
    console.log(`server is listening on ${port}`)
})