Method initSub

core/subs.go:238–258

initSub function is called on the graphjin struct to initialize a subscription.

(c context.Context, sub *sub)

// initSub function is called on the graphjin struct to initialize a subscription.
func (gj *graphjinEngine) initSub(c context.Context, sub *sub) (err error) {
	if err = sub.s.compile(); err != nil {
		return
	}

	if !gj.prod {
		err = gj.saveToAllowList(sub.s.cs.st.qc, sub.s.r.namespace)
		if err != nil {
			return
		}
	}

	// Only wrap subscriptions for batching if the dialect supports it
	targetCtx := sub.s.getTargetDBCtx()
	if len(sub.s.cs.st.md.Params()) != 0 && dialectSupportsSubscriptionBatching(targetCtx.schema.DBType()) {
		sub.s.cs.st.sql = renderSubWrap(sub.s.cs.st, targetCtx.schema.DBType())
	}

	go gj.subController(sub)
	return
}

// subController function is called on the graphjin struct to control the subscription.
func (gj *graphjinEngine) subController(sub *sub) {