user.js

import {
  http,
  gql,
  Batch,
  SQLDataSource,
  Context,
  Entity,
  ApolloGraph,
  Context,
  Schema,
  GraphManager
} from "@apollo/graph";

const USER_TYPES = gql`
  extend type Query {
    """
    The currently authenticated user root. All nodes off of this
    root will be authenticated as the current user
    """
    me: User
  }

  type User @key(fields: "id") {
    "A globally unique id for the user"
    id: ID!
    "The users full name as provided"
    name: String
    "The account username of the user"
    username: String
  }
`;

const findUser = id => {
  const { find } = SQLDataSource("postgres://user:pass@example.com:5432/dbname");
  const load = Batch(ids => find({ movies: { ids }));
  return load(id);
};

const Accounts = () => {
  const { userID } = Context(({ http }) => ({ userID: http.headers.userid });
                             
  const me = () => findUser(userID);
  const User = Entity(user => findUser(user.id));

  Schema(USER_TYPES, { Query: { me }, User });
};

const graph = ApolloGraph(() => {
  Accounts();
  GraphManager({ apiKey: "service:acephei:12345" });
});

http(graph, { port: 4000 }).then(() => console.log("Apollo Data Graph ready"));