Function removeObsoleteDesignDocs

db/design_doc.go:713–757

(ctx context.Context, viewStore sgbucket.ViewStore, previewOnly bool, useViews bool)

}

func removeObsoleteDesignDocs(ctx context.Context, viewStore sgbucket.ViewStore, previewOnly bool, useViews bool) (removedDesignDocs []string, err error) {

	removedDesignDocs = make([]string, 0)
	designDocPrefixes := []string{DesignDocSyncGatewayPrefix, DesignDocSyncHousekeepingPrefix}

	versionsToRemove := DesignDocPreviousVersions

	if !useViews {
		versionsToRemove = append(versionsToRemove, DesignDocVersion)
	}

	for _, previousVersion := range versionsToRemove {
		for _, ddocPrefix := range designDocPrefixes {
			var ddocName string
			if previousVersion == "" {
				ddocName = ddocPrefix
			} else {
				ddocName = fmt.Sprintf(DesignDocFormat, ddocPrefix, previousVersion)
			}

			if !previewOnly {
				removeDDocErr := viewStore.DeleteDDoc(ddocName)
				if removeDDocErr != nil && !IsMissingDDocError(removeDDocErr) {
					base.WarnfCtx(ctx, "Unexpected error when removing design doc %q: %s", ddocName, removeDDocErr)
				}
				// Only include in list of removedDesignDocs if it was actually removed
				if removeDDocErr == nil {
					removedDesignDocs = append(removedDesignDocs, ddocName)
				}
			} else {
				_, existsDDocErr := viewStore.GetDDoc(ddocName)
				if existsDDocErr != nil && !IsMissingDDocError(existsDDocErr) {
					base.WarnfCtx(ctx, "Unexpected error when checking existence of design doc %q: %s", ddocName, existsDDocErr)
				}
				// Only include in list of removedDesignDocs if it exists
				if existsDDocErr == nil {
					removedDesignDocs = append(removedDesignDocs, ddocName)
				}

			}
		}

	}
	return removedDesignDocs, nil
}

// Similar to IsDocNotFoundError(), but for the specific error returned by GetDDoc/DeleteDDoc
func IsMissingDDocError(err error) bool {