Revert "Removed the opengraph type dependency for plugins by stripping post Metadata (#20612)" (#20684)

This reverts commit da7a8a4552.
2022-07-20 20:09:03 +05:30
--- a/app/plugin_api.go
+++ b/app/plugin_api.go
@@ -513,7 +513,7 @@ func (api *PluginAPI) SearchPostsInTeam(teamID string, paramsList []*model.Searc
 	if err != nil {
 		return nil, err
 	}
-	return postList.ForPlugin().ToSlice(), nil
+	return postList.ToSlice(), nil
 }

 func (api *PluginAPI) SearchPostsInTeamForUser(teamID string, userID string, searchParams model.SearchParameter) (*model.PostSearchResults, *model.AppError) {
@@ -547,11 +547,7 @@ func (api *PluginAPI) SearchPostsInTeamForUser(teamID string, userID string, sea
 		includeDeletedChannels = *searchParams.IncludeDeletedChannels
 	}

-	results, appErr := api.app.SearchPostsForUser(api.ctx, terms, userID, teamID, isOrSearch, includeDeletedChannels, timeZoneOffset, page, perPage, model.ModifierMessages)
-	if results != nil {
-		results = results.ForPlugin()
-	}
-	return results, appErr
+	return api.app.SearchPostsForUser(api.ctx, terms, userID, teamID, isOrSearch, includeDeletedChannels, timeZoneOffset, page, perPage, model.ModifierMessages)
 }

 func (api *PluginAPI) AddChannelMember(channelID, userID string) (*model.ChannelMember, *model.AppError) {
@@ -631,11 +627,7 @@ func (api *PluginAPI) GetGroupsForUser(userID string) ([]*model.Group, *model.Ap
 }

 func (api *PluginAPI) CreatePost(post *model.Post) (*model.Post, *model.AppError) {
-	post, appErr := api.app.CreatePostMissingChannel(api.ctx, post, true)
-	if post != nil {
-		post = post.ForPlugin()
-	}
-	return post, appErr
+	return api.app.CreatePostMissingChannel(api.ctx, post, true)
 }

 func (api *PluginAPI) AddReaction(reaction *model.Reaction) (*model.Reaction, *model.AppError) {
@@ -651,11 +643,11 @@ func (api *PluginAPI) GetReactions(postID string) ([]*model.Reaction, *model.App
 }

 func (api *PluginAPI) SendEphemeralPost(userID string, post *model.Post) *model.Post {
-	return api.app.SendEphemeralPost(api.ctx, userID, post).ForPlugin()
+	return api.app.SendEphemeralPost(api.ctx, userID, post)
 }

 func (api *PluginAPI) UpdateEphemeralPost(userID string, post *model.Post) *model.Post {
-	return api.app.UpdateEphemeralPost(api.ctx, userID, post).ForPlugin()
+	return api.app.UpdateEphemeralPost(api.ctx, userID, post)
 }

 func (api *PluginAPI) DeleteEphemeralPost(userID, postID string) {
@@ -668,59 +660,31 @@ func (api *PluginAPI) DeletePost(postID string) *model.AppError {
 }

 func (api *PluginAPI) GetPostThread(postID string) (*model.PostList, *model.AppError) {
-	list, appErr := api.app.GetPostThread(postID, model.GetPostsOptions{}, "")
-	if list != nil {
-		list = list.ForPlugin()
-	}
-	return list, appErr
+	return api.app.GetPostThread(postID, model.GetPostsOptions{}, "")
 }

 func (api *PluginAPI) GetPost(postID string) (*model.Post, *model.AppError) {
-	post, appErr := api.app.GetSinglePost(postID, false)
-	if post != nil {
-		post = post.ForPlugin()
-	}
-	return post, appErr
+	return api.app.GetSinglePost(postID, false)
 }

 func (api *PluginAPI) GetPostsSince(channelID string, time int64) (*model.PostList, *model.AppError) {
-	list, appErr := api.app.GetPostsSince(model.GetPostsSinceOptions{ChannelId: channelID, Time: time})
-	if list != nil {
-		list = list.ForPlugin()
-	}
-	return list, appErr
+	return api.app.GetPostsSince(model.GetPostsSinceOptions{ChannelId: channelID, Time: time})
 }

 func (api *PluginAPI) GetPostsAfter(channelID, postID string, page, perPage int) (*model.PostList, *model.AppError) {
-	list, appErr := api.app.GetPostsAfterPost(model.GetPostsOptions{ChannelId: channelID, PostId: postID, Page: page, PerPage: perPage})
-	if list != nil {
-		list = list.ForPlugin()
-	}
-	return list, appErr
+	return api.app.GetPostsAfterPost(model.GetPostsOptions{ChannelId: channelID, PostId: postID, Page: page, PerPage: perPage})
 }

 func (api *PluginAPI) GetPostsBefore(channelID, postID string, page, perPage int) (*model.PostList, *model.AppError) {
-	list, appErr := api.app.GetPostsBeforePost(model.GetPostsOptions{ChannelId: channelID, PostId: postID, Page: page, PerPage: perPage})
-	if list != nil {
-		list = list.ForPlugin()
-	}
-	return list, appErr
+	return api.app.GetPostsBeforePost(model.GetPostsOptions{ChannelId: channelID, PostId: postID, Page: page, PerPage: perPage})
 }

 func (api *PluginAPI) GetPostsForChannel(channelID string, page, perPage int) (*model.PostList, *model.AppError) {
-	list, appErr := api.app.GetPostsPage(model.GetPostsOptions{ChannelId: channelID, Page: page, PerPage: perPage})
-	if list != nil {
-		list = list.ForPlugin()
-	}
-	return list, appErr
+	return api.app.GetPostsPage(model.GetPostsOptions{ChannelId: channelID, Page: page, PerPage: perPage})
 }

 func (api *PluginAPI) UpdatePost(post *model.Post) (*model.Post, *model.AppError) {
-	post, appErr := api.app.UpdatePost(api.ctx, post, false)
-	if post != nil {
-		post = post.ForPlugin()
-	}
-	return post, appErr
+	return api.app.UpdatePost(api.ctx, post, false)
 }

 func (api *PluginAPI) GetProfileImage(userID string) ([]byte, *model.AppError) {
--- a/app/post.go
+++ b/app/post.go
@@ -259,7 +259,7 @@ func (a *App) CreatePost(c request.CTX, post *model.Post, channel *model.Channel
 		var rejectionError *model.AppError
 		pluginContext := pluginContext(c)
 		pluginsEnvironment.RunMultiPluginHook(func(hooks plugin.Hooks) bool {
-			replacementPost, rejectionReason := hooks.MessageWillBePosted(pluginContext, post.ForPlugin())
+			replacementPost, rejectionReason := hooks.MessageWillBePosted(pluginContext, post)
 			if rejectionReason != "" {
 				id := "Post rejected by plugin. " + rejectionReason
 				if rejectionReason == plugin.DismissPostError {
@@ -269,7 +269,6 @@ func (a *App) CreatePost(c request.CTX, post *model.Post, channel *model.Channel
 				return false
 			}
 			if replacementPost != nil {
-				// the original post's metadata (if there ever was any) is lost, and will be rebuilt.
 				post = replacementPost
 			}

@@ -310,13 +309,21 @@ func (a *App) CreatePost(c request.CTX, post *model.Post, channel *model.Channel
 	// might be duplicating requests.
 	a.Srv().seenPendingPostIdsCache.SetWithExpiry(post.PendingPostId, rpost.Id, PendingPostIDsCacheTTL)

-	// We make a copy of the post for the plugin hook to avoid a race condition,
-	// and to remove the non-GOB-encodable Metadata from it.
+	// We make a copy of the post for the plugin hook to avoid a race condition.
+	rPostCopy := rpost.Clone()
+
+	// FIXME: Removes PreviewPost from the post payload sent to the MessageHasBeenPosted hook so that plugins compiled with older versions of
+	// Mattermost—without the gob registration of the PreviewPost struct—won't crash.
+	if rPostCopy.Metadata != nil {
+		rPostCopy.Metadata = rPostCopy.Metadata.Copy()
+	}
+	rPostCopy.RemovePreviewPost()
+
 	if pluginsEnvironment := a.GetPluginsEnvironment(); pluginsEnvironment != nil {
 		a.Srv().Go(func() {
 			pluginContext := pluginContext(c)
 			pluginsEnvironment.RunMultiPluginHook(func(hooks plugin.Hooks) bool {
-				hooks.MessageHasBeenPosted(pluginContext, rpost.ForPlugin())
+				hooks.MessageHasBeenPosted(pluginContext, rPostCopy)
 				return true
 			}, plugin.MessageHasBeenPostedID)
 		})
@@ -643,15 +650,12 @@ func (a *App) UpdatePost(c *request.Context, post *model.Post, safeUpdate bool)
 		var rejectionReason string
 		pluginContext := pluginContext(c)
 		pluginsEnvironment.RunMultiPluginHook(func(hooks plugin.Hooks) bool {
-			newPost, rejectionReason = hooks.MessageWillBeUpdated(pluginContext, newPost.ForPlugin(), oldPost.ForPlugin())
+			newPost, rejectionReason = hooks.MessageWillBeUpdated(pluginContext, newPost, oldPost)
 			return post != nil
 		}, plugin.MessageWillBeUpdatedID)
 		if newPost == nil {
 			return nil, model.NewAppError("UpdatePost", "Post rejected by plugin. "+rejectionReason, nil, "", http.StatusBadRequest)
 		}
-		// Restore the post metadata that was stripped by the plugin. Set it to
-		// the last known good.
-		newPost.Metadata = oldPost.Metadata
 	}

 	rpost, nErr := a.Srv().Store.Post().Update(newPost, oldPost)
@@ -669,7 +673,7 @@ func (a *App) UpdatePost(c *request.Context, post *model.Post, safeUpdate bool)
 		a.Srv().Go(func() {
 			pluginContext := pluginContext(c)
 			pluginsEnvironment.RunMultiPluginHook(func(hooks plugin.Hooks) bool {
-				hooks.MessageHasBeenUpdated(pluginContext, newPost.ForPlugin(), oldPost.ForPlugin())
+				hooks.MessageHasBeenUpdated(pluginContext, newPost, oldPost)
 				return true
 			}, plugin.MessageHasBeenUpdatedID)
 		})
--- a/model/post.go
+++ b/model/post.go
@@ -736,10 +736,18 @@ func (o *Post) ToNilIfInvalid() *Post {
 	return o
 }

-func (o *Post) ForPlugin() *Post {
-	p := o.Clone()
-	p.Metadata = nil
-	return p
+func (o *Post) RemovePreviewPost() {
+	if o.Metadata == nil || o.Metadata.Embeds == nil {
+		return
+	}
+	n := 0
+	for _, embed := range o.Metadata.Embeds {
+		if embed.Type != PostEmbedPermalink {
+			o.Metadata.Embeds[n] = embed
+			n++
+		}
+	}
+	o.Metadata.Embeds = o.Metadata.Embeds[:n]
 }

 func (o *Post) GetPreviewPost() *PreviewPost {
--- a/model/post_list.go
+++ b/model/post_list.go
@@ -46,14 +46,6 @@ func (o *PostList) Clone() *PostList {
 	}
 }

-func (o *PostList) ForPlugin() *PostList {
-	copy := o.Clone()
-	for k, p := range copy.Posts {
-		copy.Posts[k] = p.ForPlugin()
-	}
-	return copy
-}
-
 func (o *PostList) ToSlice() []*Post {
 	var posts []*Post

--- a/model/post_search_results.go
+++ b/model/post_search_results.go
@@ -33,9 +33,3 @@ func (o *PostSearchResults) EncodeJSON(w io.Writer) error {
 	o.PostList.StripActionIntegrations()
 	return json.NewEncoder(w).Encode(o)
 }
-
-func (o *PostSearchResults) ForPlugin() *PostSearchResults {
-	copy := *o
-	copy.PostList = copy.PostList.ForPlugin()
-	return &copy
-}
--- a/plugin/client_rpc.go
+++ b/plugin/client_rpc.go
@@ -21,6 +21,7 @@ import (
 	"reflect"
 	"sync"

+	"github.com/dyatlov/go-opengraph/opengraph"
 	"github.com/go-sql-driver/mysql"
 	"github.com/hashicorp/go-plugin"
 	"github.com/lib/pq"
@@ -163,6 +164,7 @@ func init() {
 	gob.Register(&pq.Error{})
 	gob.Register(&mysql.MySQLError{})
 	gob.Register(&ErrorString{})
+	gob.Register(&opengraph.OpenGraph{})
 	gob.Register(&model.AutocompleteDynamicListArg{})
 	gob.Register(&model.AutocompleteStaticListArg{})
 	gob.Register(&model.AutocompleteTextArg{})