Function handleOnce

internal/service/vector_sync/vector_sync.go:87–115

(ctx context.Context, data *data.Data, vectorSearch plugin.VectorSearch,
	action, objectType, objectID string)

}

func handleOnce(ctx context.Context, data *data.Data, vectorSearch plugin.VectorSearch,
	action, objectType, objectID string) error {
	if action == ActionDelete {
		return vectorSearch.DeleteContent(ctx, objectID)
	}
	if action != ActionUpsert {
		return nil
	}

	var (
		content *plugin.VectorSearchContent
		err     error
	)
	switch objectType {
	case ObjectTypeQuestion:
		content, err = vector_search_sync.BuildQuestionContentByID(ctx, data, objectID)
	case ObjectTypeAnswer:
		content, err = vector_search_sync.BuildAnswerContentByID(ctx, data, objectID)
	default:
		return nil
	}
	if err != nil {
		return err
	}
	if content == nil {
		return vectorSearch.DeleteContent(ctx, objectID)
	}
	return vectorSearch.UpdateContent(ctx, content)
}