example(apollo federation blogpost): live demo code samples (#5314)

Author: Adnan Rahić

examples/apollo-federation-with-cube/.env

@@ -0,0 +1,8 @@
+CUBEJS_DB_HOST=demo-db-examples.cube.dev
+CUBEJS_DB_PORT=5432
+CUBEJS_DB_NAME=fraud
+CUBEJS_DB_USER=cube
+CUBEJS_DB_PASS=12345
+CUBEJS_DB_TYPE=postgres
+CUBEJS_API_SECRET=SECRET
+CUBEJS_DEV_MODE=true

examples/apollo-federation-with-cube/apollo-server-app/.gitignore

@@ -0,0 +1 @@
+node_modules

examples/apollo-federation-with-cube/apollo-server-app/Dockerfile.gateway

@@ -0,0 +1,8 @@
+FROM --platform=linux/amd64 node:18.9.0-alpine3.15
+
+WORKDIR /usr/src/app
+COPY package.json package-lock.json ./
+RUN npm install --omit=dev
+COPY . ./
+
+CMD [ "node", "src/gateway.js" ]

examples/apollo-federation-with-cube/apollo-server-app/Dockerfile.server

@@ -0,0 +1,9 @@
+FROM --platform=linux/amd64 node:18.9.0-alpine3.15
+
+WORKDIR /usr/src/app
+
+COPY package.json package-lock.json ./
+RUN npm install --omit=dev
+COPY . ./
+
+CMD [ "node", "src/server.js" ]

examples/apollo-federation-with-cube/apollo-server-app/database/index.js

@@ -0,0 +1,3 @@
+const postgres = require('postgres')
+const sql = postgres('postgres://cube:[email protected]:5432/fraud', { max: 10 })
+module.exports = sql

examples/apollo-federation-with-cube/apollo-server-app/docker-compose.yaml

@@ -0,0 +1,17 @@
+version: '3'
+
+services:
+  server:
+    image: us-central1-docker.pkg.dev/cube-devrel-team/apollo-server/server
+    build:
+      context: ./
+      dockerfile: Dockerfile.server
+    ports:
+    - '4000:4000'
+  gateway:
+    image: us-central1-docker.pkg.dev/cube-devrel-team/apollo-server/gateway
+    build:
+      context: ./
+      dockerfile: Dockerfile.gateway
+    ports:
+    - '4001:4001'

examples/apollo-federation-with-cube/apollo-server-app/graphql/apollo.graphql

@@ -0,0 +1,11 @@
+type Fraud {
+  id: ID!
+  step: Float
+  type: String
+  isfraud: Int
+  amountsum: Float
+}
+
+type Query {
+  fraudsByAmountSumWithStep(isFraud: Int, stepStart: Int, stepEnd: Int): [Fraud]
+}

examples/apollo-federation-with-cube/apollo-server-app/graphql/cube.graphql

@@ -0,0 +1,123 @@
+"""
+A date-time string at UTC, such as 2007-12-03T10:15:30Z, compliant with the `date-time` format outlined in section 5.6 of the RFC 3339 profile of the ISO 8601 standard for representation of dates and times using the Gregorian calendar.
+"""
+scalar DateTime
+
+input FloatFilter {
+  equals: Float
+  notEquals: Float
+  in: [Float]
+  notIn: [Float]
+  set: Boolean
+  gt: Float
+  lt: Float
+  gte: Float
+  lte: Float
+}
+
+input StringFilter {
+  equals: String
+  notEquals: String
+  in: [String]
+  notIn: [String]
+  contains: String
+  notContains: String
+  set: Boolean
+}
+
+input DateTimeFilter {
+  equals: String
+  notEquals: String
+  in: [String]
+  notIn: [String]
+  inDateRange: [String]
+  notInDateRange: [String]
+  beforeDate: String
+  afterDate: String
+  set: Boolean
+}
+
+enum OrderBy {
+  asc
+  desc
+}
+
+type TimeDimension {
+  value: DateTime!
+  second: DateTime!
+  minute: DateTime!
+  hour: DateTime!
+  day: DateTime!
+  week: DateTime!
+  month: DateTime!
+  quarter: DateTime!
+  year: DateTime!
+}
+
+type FraudMembers {
+  count: Float
+  amountSum: Float
+  step: Float
+  newbalancedest: String
+  nameorig: String
+  oldbalanceorg: String
+  namedest: String
+  newbalanceorg: String
+  oldbalancedest: String
+  type: String
+  amount: Float
+  isFraud: String
+  isFlaggedFraud: String
+}
+
+input FraudWhereInput {
+  AND: [FraudWhereInput!]
+  OR: [FraudWhereInput!]
+  count: FloatFilter
+  amountSum: FloatFilter
+  step: FloatFilter
+  newbalancedest: StringFilter
+  nameorig: StringFilter
+  oldbalanceorg: StringFilter
+  namedest: StringFilter
+  newbalanceorg: StringFilter
+  oldbalancedest: StringFilter
+  type: StringFilter
+  amount: FloatFilter
+  isFraud: StringFilter
+  isFlaggedFraud: StringFilter
+}
+
+input FraudOrderByInput {
+  count: OrderBy
+  amountSum: OrderBy
+  step: OrderBy
+  newbalancedest: OrderBy
+  nameorig: OrderBy
+  oldbalanceorg: OrderBy
+  namedest: OrderBy
+  newbalanceorg: OrderBy
+  oldbalancedest: OrderBy
+  type: OrderBy
+  amount: OrderBy
+  isFraud: OrderBy
+  isFlaggedFraud: OrderBy
+}
+
+input RootWhereInput {
+  AND: [RootWhereInput!]
+  OR: [RootWhereInput!]
+  fraud: FraudWhereInput
+}
+
+input RootOrderByInput {
+  fraud: FraudOrderByInput
+}
+
+type Result {
+  fraud(where: FraudWhereInput, orderBy: FraudOrderByInput): FraudMembers!
+}
+
+type Query {
+  cube(where: RootWhereInput, limit: Int, offset: Int, timezone: String, renewQuery: Boolean, orderBy: RootOrderByInput): [Result!]!
+}

examples/apollo-federation-with-cube/apollo-server-app/graphql/fraud.js

@@ -0,0 +1,43 @@
+const { gql } = require('apollo-server-express')
+const sql = require('../database')
+
+async function amountSumFraudsWithStep({ isFraud, stepStart, stepEnd }) {
+  return sql`
+    SELECT
+      "fraud"."isFraud" as isfraud,
+      "fraud"."step" as step,
+      "fraud"."type" as type,
+      sum("fraud"."amount") as amountsum
+    FROM public.fraud AS "fraud"
+    WHERE
+      "fraud"."isFraud" = ${isFraud} 
+        AND 
+      "fraud"."step" BETWEEN ${stepStart} AND ${stepEnd}
+    GROUP BY 1, 2, 3
+    ORDER BY 1 ASC;
+  `
+}
+
+module.exports = {
+  typeDefs: gql`
+    extend type Query {
+      fraudsByAmountSumWithStep(isFraud: Int, stepStart: Int, stepEnd: Int): [Fraud]
+    }
+
+    type Fraud {
+      id: ID!
+      step: Float
+      type: String
+      isfraud: Int
+      amountsum: Float
+    }
+  `,
+  resolvers: {
+    Query: {
+      fraudsByAmountSumWithStep: async (obj, args, context, info) =>
+        amountSumFraudsWithStep(
+          { isFraud: args.isFraud, stepStart: args.stepStart, stepEnd: args.stepEnd }
+        )
+    },
+  }
+}