Method setupBunStore

pkg/identityserver/store.go:33–49

()

}

func (is *IdentityServer) setupBunStore() (err error) {
	is.db, err = storeutil.OpenDB(is.Context(), is.config.DatabaseURI)
	if err != nil {
		return err
	}
	bunDB := bun.NewDB(is.db, pgdialect.New())
	if is.LogDebug() {
		bunDB.AddQueryHook(storeutil.NewLoggerHook(log.FromContext(is.Context()).WithField("namespace", "db")))
	}
	bunStore, err := bunstore.NewStore(is.Context(), bunDB)
	if err != nil {
		return err
	}
	is.store = bunStore

	return nil
}