ragokan

const { generateApi } = require("swagger-typescript-api");
const path = require("path");
const fs = require("fs");

const output = path.resolve(process.cwd(), "./src/services");

generateApi({
  url: "http://localhost:8000/api-json",
  output,
  generateClient: true,

ragokan

package main

import (
	"encoding/json"
	"github.com/streadway/amqp"
	. "gofast/helpers"
	. "gofast/types"
	"log"
)

ragokan

import Redis from "ioredis";

// Create pub and sub clients
const sub = new Redis();
const pub = new Redis();

// Set the queue names
const queue = "getHello";
const replyQueue = `${queue}.reply`;

ragokan

import amqp, { Message, Channel } from "amqplib/callback_api";

const handleMessage = (message: Message, channel: Channel) => {
  // Parse message
  const content = JSON.parse(message.content.toString()) as IncomingMessage;

  // Get properties
  const { replyTo, correlationId } = message.properties;

  // Reply to message 5 times

ragokan

import { Prisma } from "@prisma/client";
import Redis from "ioredis";

const mutationActions = ["create", "update", "delete", "deleteMany", "updateMany"];
const queryActions = ["findUnique", "findMany", "count"];
const allActions = [...mutationActions, ...queryActions];

export function cacheMiddleware(
  redis: Redis,
  cacheDuration = 100 // 100 seconds