@@ -16,7 +16,7 @@ import { isBillingEnabled } from "../../../gcp/cloudbilling";
1616import { trackGA4 } from "../../../track" ;
1717import { Source } from "." ;
1818
19- export interface SchemaRequiredInfo {
19+ export interface ResolverRequiredInfo {
2020 id : string ;
2121 uri : string ;
2222 serviceInfo : ServiceInfo ;
@@ -26,7 +26,7 @@ export async function askQuestions(setup: Setup, config: Config): Promise<void>
2626 if ( ! experiments . isEnabled ( "fdcwebhooks" ) ) {
2727 throw new Error ( "Unsupported command." ) ;
2828 }
29- const schemaInfo : SchemaRequiredInfo = {
29+ const resolverInfo : ResolverRequiredInfo = {
3030 id : "" ,
3131 uri : "" ,
3232 serviceInfo : { } as ServiceInfo ,
@@ -38,7 +38,7 @@ export async function askQuestions(setup: Setup, config: Config): Promise<void>
3838 `No Firebase Data Connect workspace found. Run ${ clc . bold ( "firebase init dataconnect" ) } to set up a service and main schema.` ,
3939 ) ;
4040 } else if ( serviceInfos . length === 1 ) {
41- schemaInfo . serviceInfo = serviceInfos [ 0 ] ;
41+ resolverInfo . serviceInfo = serviceInfos [ 0 ] ;
4242 } else {
4343 const choices : Array < { name : string ; value : ServiceInfo } > = serviceInfos . map ( ( si ) => {
4444 const serviceName = parseServiceName ( si . serviceName ) ;
@@ -47,41 +47,41 @@ export async function askQuestions(setup: Setup, config: Config): Promise<void>
4747 value : si ,
4848 } ;
4949 } ) ;
50- schemaInfo . serviceInfo = await select < ServiceInfo > ( {
51- message : "Which service would you like to set up a secondary schema for?" ,
50+ resolverInfo . serviceInfo = await select < ServiceInfo > ( {
51+ message : "Which service would you like to set up a custom resolver for?" ,
5252 choices,
5353 } ) ;
5454 }
5555
56- schemaInfo . id = await input ( {
57- message : `What ID would you like to use for your secondary schema ?` ,
56+ resolverInfo . id = await input ( {
57+ message : `What ID would you like to use for your custom resolver ?` ,
5858 default : newUniqueId (
5959 `resolver` ,
60- schemaInfo . serviceInfo . dataConnectYaml . schemas ?. map ( ( sch ) => sch . id || "" ) || [ ] ,
60+ resolverInfo . serviceInfo . dataConnectYaml . schemas ?. map ( ( sch ) => sch . id || "" ) || [ ] ,
6161 ) ,
6262 } ) ;
63- schemaInfo . uri = await input ( {
64- message : `What is the URL of your Cloud Run data source that implements your secondary schema ?` ,
65- default : `https://${ schemaInfo . id } -${ setup . projectNumber || "PROJECT_NUMBER" } .${ FDC_DEFAULT_REGION } .run.app/graphql` ,
63+ resolverInfo . uri = await input ( {
64+ message : `What is the URL of your Cloud Run data source that implements your custom resolver ?` ,
65+ default : `https://${ resolverInfo . id } -${ setup . projectNumber || "PROJECT_NUMBER" } .${ FDC_DEFAULT_REGION } .run.app/graphql` ,
6666 } ) ;
6767
6868 setup . featureInfo = setup . featureInfo || { } ;
69- setup . featureInfo . dataconnectSchema = schemaInfo ;
69+ setup . featureInfo . dataconnectResolver = resolverInfo ;
7070}
7171
7272export async function actuate ( setup : Setup , config : Config ) {
7373 if ( ! experiments . isEnabled ( "fdcwebhooks" ) ) {
7474 return ;
7575 }
76- const schemaInfo = setup . featureInfo ?. dataconnectSchema ;
77- if ( ! schemaInfo ) {
78- throw new Error ( "Data Connect schema feature SchemaRequiredInfo not provided" ) ;
76+ const resolverInfo = setup . featureInfo ?. dataconnectResolver ;
77+ if ( ! resolverInfo ) {
78+ throw new Error ( "Data Connect resolver feature ResolverRequiredInfo not provided" ) ;
7979 }
8080 const startTime = Date . now ( ) ;
8181 try {
82- actuateWithInfo ( config , schemaInfo ) ;
82+ actuateWithInfo ( config , resolverInfo ) ;
8383 } finally {
84- const source : Source = "init_schema " ;
84+ const source : Source = "init_resolver " ;
8585 void trackGA4 (
8686 "dataconnect_init" ,
8787 {
@@ -98,7 +98,7 @@ export async function actuate(setup: Setup, config: Config) {
9898 }
9999}
100100
101- function actuateWithInfo ( config : Config , info : SchemaRequiredInfo ) {
101+ function actuateWithInfo ( config : Config , info : ResolverRequiredInfo ) {
102102 const dataConnectYaml = JSON . parse (
103103 JSON . stringify ( info . serviceInfo ?. dataConnectYaml ) ,
104104 ) as DataConnectYaml ;
@@ -118,7 +118,7 @@ function actuateWithInfo(config: Config, info: SchemaRequiredInfo) {
118118/** Add secondary schema configuration to dataconnect.yaml in place */
119119export function addSchemaToDataConnectYaml (
120120 dataConnectYaml : DataConnectYaml ,
121- info : SchemaRequiredInfo ,
121+ info : ResolverRequiredInfo ,
122122) : void {
123123 const secondarySchema : SchemaYaml = {
124124 source : `./schema_${ info . id } ` ,
0 commit comments