mirror of https://github.com/Chocobozzz/PeerTube
				
				
				
			Use search client scope
							parent
							
								
									93cae47925
								
							
						
					
					
						commit
						e8f902c05c
					
				| 
						 | 
				
			
			@ -28,6 +28,7 @@ export class PluginService implements ClientHook {
 | 
			
		|||
 | 
			
		||||
  pluginsLoaded: { [ scope in PluginClientScope ]: ReplaySubject<boolean> } = {
 | 
			
		||||
    common: new ReplaySubject<boolean>(1),
 | 
			
		||||
    search: new ReplaySubject<boolean>(1),
 | 
			
		||||
    'video-watch': new ReplaySubject<boolean>(1)
 | 
			
		||||
  }
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			@ -109,7 +110,11 @@ export class PluginService implements ClientHook {
 | 
			
		|||
      if (!isReload) this.loadedScopes.push(scope)
 | 
			
		||||
 | 
			
		||||
      const toLoad = this.scopes[ scope ]
 | 
			
		||||
      if (!Array.isArray(toLoad)) return
 | 
			
		||||
      if (!Array.isArray(toLoad)) {
 | 
			
		||||
        this.pluginsLoaded[scope].next(true)
 | 
			
		||||
 | 
			
		||||
        return
 | 
			
		||||
      }
 | 
			
		||||
 | 
			
		||||
      const promises: Promise<any>[] = []
 | 
			
		||||
      for (const pluginInfo of toLoad) {
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -11,6 +11,7 @@ import { VideoChannel } from '@app/shared/video-channel/video-channel.model'
 | 
			
		|||
import { immutableAssign } from '@app/shared/misc/utils'
 | 
			
		||||
import { Video } from '@app/shared/video/video.model'
 | 
			
		||||
import { HooksService } from '@app/core/plugins/hooks.service'
 | 
			
		||||
import { PluginService } from '@app/core/plugins/plugin.service'
 | 
			
		||||
 | 
			
		||||
@Component({
 | 
			
		||||
  selector: 'my-search',
 | 
			
		||||
| 
						 | 
				
			
			@ -43,7 +44,8 @@ export class SearchComponent implements OnInit, OnDestroy {
 | 
			
		|||
    private notifier: Notifier,
 | 
			
		||||
    private searchService: SearchService,
 | 
			
		||||
    private authService: AuthService,
 | 
			
		||||
    private hooks: HooksService
 | 
			
		||||
    private hooks: HooksService,
 | 
			
		||||
    private pluginService: PluginService
 | 
			
		||||
  ) { }
 | 
			
		||||
 | 
			
		||||
  get user () {
 | 
			
		||||
| 
						 | 
				
			
			@ -51,6 +53,8 @@ export class SearchComponent implements OnInit, OnDestroy {
 | 
			
		|||
  }
 | 
			
		||||
 | 
			
		||||
  ngOnInit () {
 | 
			
		||||
    this.pluginService.loadPluginsByScope('search')
 | 
			
		||||
 | 
			
		||||
    this.subActivatedRoute = this.route.queryParams.subscribe(
 | 
			
		||||
      queryParams => {
 | 
			
		||||
        const querySearch = queryParams['search']
 | 
			
		||||
| 
						 | 
				
			
			@ -175,7 +179,7 @@ export class SearchComponent implements OnInit, OnDestroy {
 | 
			
		|||
    return this.hooks.wrapObsFun(
 | 
			
		||||
      this.searchService.searchVideos.bind(this.searchService),
 | 
			
		||||
      params,
 | 
			
		||||
      'common',
 | 
			
		||||
      'search',
 | 
			
		||||
      'filter:api.search.videos.list.params',
 | 
			
		||||
      'filter:api.search.videos.list.result'
 | 
			
		||||
    )
 | 
			
		||||
| 
						 | 
				
			
			@ -190,7 +194,7 @@ export class SearchComponent implements OnInit, OnDestroy {
 | 
			
		|||
    return this.hooks.wrapObsFun(
 | 
			
		||||
      this.searchService.searchVideoChannels.bind(this.searchService),
 | 
			
		||||
      params,
 | 
			
		||||
      'common',
 | 
			
		||||
      'search',
 | 
			
		||||
      'filter:api.search.video-channels.list.params',
 | 
			
		||||
      'filter:api.search.video-channels.list.result'
 | 
			
		||||
    )
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -52,7 +52,7 @@ export class VideoCommentService {
 | 
			
		|||
    videoId: number | string,
 | 
			
		||||
    componentPagination: ComponentPagination,
 | 
			
		||||
    sort: VideoSortField
 | 
			
		||||
  }): Observable<{ comments: VideoComment[], totalComments: number}> {
 | 
			
		||||
  }): Observable<ResultList<VideoComment>> {
 | 
			
		||||
    const { videoId, componentPagination, sort } = parameters
 | 
			
		||||
 | 
			
		||||
    const pagination = this.restService.componentPaginationToRestPagination(componentPagination)
 | 
			
		||||
| 
						 | 
				
			
			@ -61,10 +61,9 @@ export class VideoCommentService {
 | 
			
		|||
    params = this.restService.addRestGetParams(params, pagination, sort)
 | 
			
		||||
 | 
			
		||||
    const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comment-threads'
 | 
			
		||||
    return this.authHttp
 | 
			
		||||
               .get(url, { params })
 | 
			
		||||
    return this.authHttp.get<ResultList<VideoComment>>(url, { params })
 | 
			
		||||
               .pipe(
 | 
			
		||||
                 map(this.extractVideoComments),
 | 
			
		||||
                 map(result => this.extractVideoComments(result)),
 | 
			
		||||
                 catchError(err => this.restExtractor.handleError(err))
 | 
			
		||||
               )
 | 
			
		||||
  }
 | 
			
		||||
| 
						 | 
				
			
			@ -136,7 +135,7 @@ export class VideoCommentService {
 | 
			
		|||
      comments.push(new VideoComment(videoCommentJson))
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    return { comments, totalComments }
 | 
			
		||||
    return { data: comments, total: totalComments }
 | 
			
		||||
  }
 | 
			
		||||
 | 
			
		||||
  private extractVideoCommentTree (tree: VideoCommentThreadTree) {
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -122,8 +122,8 @@ export class VideoCommentsComponent implements OnInit, OnChanges, OnDestroy {
 | 
			
		|||
 | 
			
		||||
    obs.subscribe(
 | 
			
		||||
      res => {
 | 
			
		||||
        this.comments = this.comments.concat(res.comments)
 | 
			
		||||
        this.componentPagination.totalItems = res.totalComments
 | 
			
		||||
        this.comments = this.comments.concat(res.data)
 | 
			
		||||
        this.componentPagination.totalItems = res.total
 | 
			
		||||
      },
 | 
			
		||||
 | 
			
		||||
      err => this.notifier.error(err.message)
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -103,7 +103,7 @@ export class VideoWatchComponent implements OnInit, OnDestroy {
 | 
			
		|||
  }
 | 
			
		||||
 | 
			
		||||
  async ngOnInit () {
 | 
			
		||||
    await this.pluginService.loadPluginsByScope('video-watch')
 | 
			
		||||
    this.pluginService.loadPluginsByScope('video-watch')
 | 
			
		||||
 | 
			
		||||
    this.configSub = this.serverService.configLoaded
 | 
			
		||||
        .subscribe(() => {
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1 +1 @@
 | 
			
		|||
export type PluginClientScope = 'common' | 'video-watch'
 | 
			
		||||
export type PluginClientScope = 'common' | 'video-watch' | 'search'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,8 @@
 | 
			
		|||
import { PluginClientScope } from './plugin-client-scope.type'
 | 
			
		||||
 | 
			
		||||
export type ClientScript = {
 | 
			
		||||
  script: string,
 | 
			
		||||
  scopes: string[]
 | 
			
		||||
  scopes: PluginClientScope[]
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export type PluginPackageJson = {
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,12 +1,11 @@
 | 
			
		|||
import { NSFWPolicyType } from '../videos/nsfw-policy.type'
 | 
			
		||||
import { ClientScript } from '../plugins/plugin-package-json.model'
 | 
			
		||||
import { PluginClientScope } from '../plugins/plugin-scope.type'
 | 
			
		||||
 | 
			
		||||
export interface ServerConfigPlugin {
 | 
			
		||||
  name: string
 | 
			
		||||
  version: string
 | 
			
		||||
  description: string
 | 
			
		||||
  clientScripts: { [name in PluginClientScope]: ClientScript }
 | 
			
		||||
  clientScripts: { [name: string]: ClientScript }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export interface ServerConfigTheme extends ServerConfigPlugin {
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
		Reference in New Issue