Method handleFlush

rest/api.go:276–351

()

}

func (h *handler) handleFlush() error {

	baseBucket := base.GetBaseBucket(h.db.Bucket)

	// If it can be flushed, then flush it
	if _, ok := baseBucket.(sgbucket.FlushableStore); ok {

		// If it's not a walrus bucket, don't allow flush unless the unsupported config is set
		if !h.db.BucketSpec.IsWalrusBucket() {
			if !h.db.DatabaseContext.AllowFlushNonCouchbaseBuckets() {
				return errors.New("Flush not allowed on Couchbase buckets by default.")
			}
		}

		name := h.db.Name
		config := h.server.GetDatabaseConfig(name)

		// This needs to first call RemoveDatabase since flushing the bucket under Sync Gateway might cause issues.
		h.server.RemoveDatabase(h.ctx(), name, fmt.Sprintf("called from %s", h.rq.URL))

		// Create a bucket connection spec from the database config
		spec, err := GetBucketSpec(h.ctx(), &config.DatabaseConfig, h.server.Config)
		if err != nil {
			return err
		}

		// Manually re-open a temporary bucket connection just for flushing purposes
		tempBucketForFlush, err := db.ConnectToBucket(h.ctx(), spec, false)
		if err != nil {
			return err
		}
		defer tempBucketForFlush.Close(h.ctx()) // Close the temporary connection to the bucket that was just for purposes of flushing it

		// Flush the bucket (assuming it conforms to sgbucket.DeleteableStore interface
		if tempBucketForFlush, ok := tempBucketForFlush.(sgbucket.FlushableStore); ok {

			// Flush
			err := tempBucketForFlush.Flush()
			if err != nil {
				return err
			}

		}

		// Re-open database and add to Sync Gateway
		_, err2 := h.server.AddDatabaseFromConfig(h.ctx(), config.DatabaseConfig)
		if err2 != nil {
			return err2
		}
		base.Audit(h.ctx(), base.AuditIDDatabaseFlush, nil)

	} else if bucket, ok := baseBucket.(sgbucket.DeleteableStore); ok {

		// If it's not flushable, but it's deletable, then delete it

		name := h.db.Name
		config := h.server.GetDatabaseConfig(name)
		h.server.RemoveDatabase(h.ctx(), name, fmt.Sprintf("called from %s", h.rq.URL))