Method schemaJSONFile

core/schema/query.go:189–223

(
	ctx context.Context,
	parent dagql.ObjectResult[*core.Query],
	args schemaJSONArgs,
)

}

func (s *querySchema) schemaJSONFile(
	ctx context.Context,
	parent dagql.ObjectResult[*core.Query],
	args schemaJSONArgs,
) (inst dagql.ObjectResult[*core.File], rerr error) {
	const schemaJSONFilename = "schema.json"
	const perm fs.FileMode = 0644

	dag, err := core.CurrentDagqlServer(ctx)
	if err != nil {
		return inst, err
	}

	moduleSchemaJSON, err := getSchemaJSON(args.HiddenTypes, dag.View, dag)
	if err != nil {
		return inst, err
	}

	var dirInst dagql.ObjectResult[*core.Directory]
	if err := dag.Select(ctx, dag.Root(), &dirInst, dagql.Selector{Field: "directory"}); err != nil {
		return inst, err
	}

	file := &core.File{
		Platform: parent.Self().Platform(),
		File:     new(core.LazyAccessor[string, *core.File]),
		Snapshot: new(core.LazyAccessor[bkcache.ImmutableRef, *core.File]),
	}

	if err := file.WithContents(ctx, dirInst, schemaJSONFilename, moduleSchemaJSON, perm, nil); err != nil {
		return inst, err
	}

	return dagql.NewObjectResultForCurrentCall(ctx, dag, file)
}