INNER CODE UNIT · Go

NewAdapter

apache/casbin-mongodb-adapter · adapter.go:65

func NewAdapter(url string, timeout ...interface{}) (persist.BatchAdapter, error) {
	if !strings.HasPrefix(url, "mongodb+srv://") && !strings.HasPrefix(url, "mongodb://") {
		url = fmt.Sprint("mongodb://" + url)
	}

	// Parse and validate url before apply it.
	connString, err := connstring.ParseAndValidate(url)

	if err != nil {
		return nil, err
	}

	clientOption := options.Client().ApplyURI(url)

	var databaseName string
	// Get database name from connString.
	if connString.Database != "" {
		databaseName = connString.Database

View source record →