parent
350e31d6b6
commit
51548b3181
|
@ -4,7 +4,7 @@ import { RouterModule, Routes } from '@angular/router'
|
||||||
import { MetaGuard } from '@ngx-meta/core'
|
import { MetaGuard } from '@ngx-meta/core'
|
||||||
|
|
||||||
import { AdminComponent } from './admin.component'
|
import { AdminComponent } from './admin.component'
|
||||||
import { FriendsRoutes } from './friends'
|
import { FollowsRoutes } from './follows'
|
||||||
import { UsersRoutes } from './users'
|
import { UsersRoutes } from './users'
|
||||||
import { VideoAbusesRoutes } from './video-abuses'
|
import { VideoAbusesRoutes } from './video-abuses'
|
||||||
import { VideoBlacklistRoutes } from './video-blacklist'
|
import { VideoBlacklistRoutes } from './video-blacklist'
|
||||||
|
@ -21,7 +21,7 @@ const adminRoutes: Routes = [
|
||||||
redirectTo: 'users',
|
redirectTo: 'users',
|
||||||
pathMatch: 'full'
|
pathMatch: 'full'
|
||||||
},
|
},
|
||||||
...FriendsRoutes,
|
...FollowsRoutes,
|
||||||
...UsersRoutes,
|
...UsersRoutes,
|
||||||
...VideoAbusesRoutes,
|
...VideoAbusesRoutes,
|
||||||
...VideoBlacklistRoutes
|
...VideoBlacklistRoutes
|
||||||
|
|
|
@ -1,25 +1,28 @@
|
||||||
import { NgModule } from '@angular/core'
|
import { NgModule } from '@angular/core'
|
||||||
|
import { TabsModule } from 'ngx-bootstrap/tabs'
|
||||||
import { AdminComponent } from './admin.component'
|
|
||||||
import { AdminRoutingModule } from './admin-routing.module'
|
|
||||||
import { FriendsComponent, FriendAddComponent, FriendListComponent, FriendService } from './friends'
|
|
||||||
import { UsersComponent, UserAddComponent, UserUpdateComponent, UserListComponent, UserService } from './users'
|
|
||||||
import { VideoAbusesComponent, VideoAbuseListComponent } from './video-abuses'
|
|
||||||
import { VideoBlacklistComponent, VideoBlacklistListComponent } from './video-blacklist'
|
|
||||||
import { SharedModule } from '../shared'
|
import { SharedModule } from '../shared'
|
||||||
|
import { AdminRoutingModule } from './admin-routing.module'
|
||||||
|
import { AdminComponent } from './admin.component'
|
||||||
|
import { FollowersListComponent, FollowingAddComponent, FollowsComponent, FollowService } from './follows'
|
||||||
|
import { FollowingListComponent } from './follows/following-list/following-list.component'
|
||||||
|
import { UserAddComponent, UserListComponent, UsersComponent, UserService, UserUpdateComponent } from './users'
|
||||||
|
import { VideoAbuseListComponent, VideoAbusesComponent } from './video-abuses'
|
||||||
|
import { VideoBlacklistComponent, VideoBlacklistListComponent } from './video-blacklist'
|
||||||
|
|
||||||
@NgModule({
|
@NgModule({
|
||||||
imports: [
|
imports: [
|
||||||
AdminRoutingModule,
|
AdminRoutingModule,
|
||||||
|
TabsModule.forRoot(),
|
||||||
SharedModule
|
SharedModule
|
||||||
],
|
],
|
||||||
|
|
||||||
declarations: [
|
declarations: [
|
||||||
AdminComponent,
|
AdminComponent,
|
||||||
|
|
||||||
FriendsComponent,
|
FollowsComponent,
|
||||||
FriendAddComponent,
|
FollowingAddComponent,
|
||||||
FriendListComponent,
|
FollowersListComponent,
|
||||||
|
FollowingListComponent,
|
||||||
|
|
||||||
UsersComponent,
|
UsersComponent,
|
||||||
UserAddComponent,
|
UserAddComponent,
|
||||||
|
@ -38,7 +41,7 @@ import { SharedModule } from '../shared'
|
||||||
],
|
],
|
||||||
|
|
||||||
providers: [
|
providers: [
|
||||||
FriendService,
|
FollowService,
|
||||||
UserService
|
UserService
|
||||||
]
|
]
|
||||||
})
|
})
|
||||||
|
|
|
@ -0,0 +1,16 @@
|
||||||
|
<div class="row">
|
||||||
|
<div class="content-padding">
|
||||||
|
<h3>Followers list</h3>
|
||||||
|
|
||||||
|
<p-dataTable
|
||||||
|
[value]="followers" [lazy]="true" [paginator]="true" [totalRecords]="totalRecords" [rows]="rowsPerPage"
|
||||||
|
sortField="createdAt" (onLazyLoad)="loadLazy($event)"
|
||||||
|
>
|
||||||
|
<p-column field="id" header="ID"></p-column>
|
||||||
|
<p-column field="host" header="Host"></p-column>
|
||||||
|
<p-column field="email" header="Email"></p-column>
|
||||||
|
<p-column field="score" header="Score"></p-column>
|
||||||
|
<p-column field="createdAt" header="Created date" [sortable]="true"></p-column>
|
||||||
|
</p-dataTable>
|
||||||
|
</div>
|
||||||
|
</div>
|
|
@ -0,0 +1,41 @@
|
||||||
|
import { Component, OnInit } from '@angular/core'
|
||||||
|
|
||||||
|
import { NotificationsService } from 'angular2-notifications'
|
||||||
|
import { SortMeta } from 'primeng/primeng'
|
||||||
|
|
||||||
|
import { ConfirmService } from '../../../core'
|
||||||
|
import { RestTable, RestPagination } from '../../../shared'
|
||||||
|
import { Pod } from '../../../../../../shared'
|
||||||
|
import { FollowService } from '../shared'
|
||||||
|
|
||||||
|
@Component({
|
||||||
|
selector: 'my-followers-list',
|
||||||
|
templateUrl: './followers-list.component.html',
|
||||||
|
styleUrls: [ './followers-list.component.scss' ]
|
||||||
|
})
|
||||||
|
export class FollowersListComponent extends RestTable {
|
||||||
|
followers: Pod[] = []
|
||||||
|
totalRecords = 0
|
||||||
|
rowsPerPage = 10
|
||||||
|
sort: SortMeta = { field: 'createdAt', order: 1 }
|
||||||
|
pagination: RestPagination = { count: this.rowsPerPage, start: 0 }
|
||||||
|
|
||||||
|
constructor (
|
||||||
|
private notificationsService: NotificationsService,
|
||||||
|
private followService: FollowService
|
||||||
|
) {
|
||||||
|
super()
|
||||||
|
}
|
||||||
|
|
||||||
|
protected loadData () {
|
||||||
|
this.followService.getFollowers(this.pagination, this.sort)
|
||||||
|
.subscribe(
|
||||||
|
resultList => {
|
||||||
|
this.followers = resultList.data
|
||||||
|
this.totalRecords = resultList.total
|
||||||
|
},
|
||||||
|
|
||||||
|
err => this.notificationsService.error('Error', err.message)
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1 @@
|
||||||
|
export * from './followers-list.component'
|
|
@ -1,11 +1,11 @@
|
||||||
<div class="row">
|
<div class="row">
|
||||||
<div class="content-padding">
|
<div class="content-padding">
|
||||||
|
|
||||||
<h3>Make friends</h3>
|
<h3>Add following</h3>
|
||||||
|
|
||||||
<div *ngIf="error" class="alert alert-danger">{{ error }}</div>
|
<div *ngIf="error" class="alert alert-danger">{{ error }}</div>
|
||||||
|
|
||||||
<form (ngSubmit)="makeFriends()" [formGroup]="form">
|
<form (ngSubmit)="addFollowing()" [formGroup]="form">
|
||||||
<div class="form-group" *ngFor="let host of hosts; let id = index; trackBy:customTrackBy">
|
<div class="form-group" *ngFor="let host of hosts; let id = index; trackBy:customTrackBy">
|
||||||
<label [for]="'host-' + id">Host (so without "http://")</label>
|
<label [for]="'host-' + id">Host (so without "http://")</label>
|
||||||
|
|
||||||
|
@ -26,10 +26,10 @@
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div *ngIf="canMakeFriends() === false" class="alert alert-warning">
|
<div *ngIf="canMakeFriends() === false" class="alert alert-warning">
|
||||||
It seems that you are not on a HTTPS pod. Your webserver need to have TLS activated in order to make friends.
|
It seems that you are not on a HTTPS pod. Your webserver need to have TLS activated in order to follow servers.
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<input type="submit" value="Make friends" class="btn btn-default" [disabled]="!isFormValid()">
|
<input type="submit" value="Add following" class="btn btn-default" [disabled]="!isFormValid()">
|
||||||
</form>
|
</form>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
|
@ -6,14 +6,14 @@ import { NotificationsService } from 'angular2-notifications'
|
||||||
|
|
||||||
import { ConfirmService } from '../../../core'
|
import { ConfirmService } from '../../../core'
|
||||||
import { validateHost } from '../../../shared'
|
import { validateHost } from '../../../shared'
|
||||||
import { FriendService } from '../shared'
|
import { FollowService } from '../shared'
|
||||||
|
|
||||||
@Component({
|
@Component({
|
||||||
selector: 'my-friend-add',
|
selector: 'my-following-add',
|
||||||
templateUrl: './friend-add.component.html',
|
templateUrl: './following-add.component.html',
|
||||||
styleUrls: [ './friend-add.component.scss' ]
|
styleUrls: [ './following-add.component.scss' ]
|
||||||
})
|
})
|
||||||
export class FriendAddComponent implements OnInit {
|
export class FollowingAddComponent implements OnInit {
|
||||||
form: FormGroup
|
form: FormGroup
|
||||||
hosts: string[] = [ ]
|
hosts: string[] = [ ]
|
||||||
error: string = null
|
error: string = null
|
||||||
|
@ -22,7 +22,7 @@ export class FriendAddComponent implements OnInit {
|
||||||
private router: Router,
|
private router: Router,
|
||||||
private notificationsService: NotificationsService,
|
private notificationsService: NotificationsService,
|
||||||
private confirmService: ConfirmService,
|
private confirmService: ConfirmService,
|
||||||
private friendService: FriendService
|
private followService: FollowService
|
||||||
) {}
|
) {}
|
||||||
|
|
||||||
ngOnInit () {
|
ngOnInit () {
|
||||||
|
@ -72,7 +72,7 @@ export class FriendAddComponent implements OnInit {
|
||||||
this.hosts.splice(index, 1)
|
this.hosts.splice(index, 1)
|
||||||
}
|
}
|
||||||
|
|
||||||
makeFriends () {
|
addFollowing () {
|
||||||
this.error = ''
|
this.error = ''
|
||||||
|
|
||||||
const notEmptyHosts = this.getNotEmptyHosts()
|
const notEmptyHosts = this.getNotEmptyHosts()
|
||||||
|
@ -87,13 +87,13 @@ export class FriendAddComponent implements OnInit {
|
||||||
}
|
}
|
||||||
|
|
||||||
const confirmMessage = 'Are you sure to make friends with:<br /> - ' + notEmptyHosts.join('<br /> - ')
|
const confirmMessage = 'Are you sure to make friends with:<br /> - ' + notEmptyHosts.join('<br /> - ')
|
||||||
this.confirmService.confirm(confirmMessage, 'Make friends').subscribe(
|
this.confirmService.confirm(confirmMessage, 'Follow new server(s)').subscribe(
|
||||||
res => {
|
res => {
|
||||||
if (res === false) return
|
if (res === false) return
|
||||||
|
|
||||||
this.friendService.follow(notEmptyHosts).subscribe(
|
this.followService.follow(notEmptyHosts).subscribe(
|
||||||
status => {
|
status => {
|
||||||
this.notificationsService.success('Success', 'Make friends request sent!')
|
this.notificationsService.success('Success', 'Follow request(s) sent!')
|
||||||
// Wait requests between pods
|
// Wait requests between pods
|
||||||
setTimeout(() => this.router.navigate([ '/admin/friends/list' ]), 1000)
|
setTimeout(() => this.router.navigate([ '/admin/friends/list' ]), 1000)
|
||||||
},
|
},
|
|
@ -0,0 +1 @@
|
||||||
|
export * from './following-add.component'
|
|
@ -0,0 +1,16 @@
|
||||||
|
<div class="row">
|
||||||
|
<div class="content-padding">
|
||||||
|
<h3>Following list</h3>
|
||||||
|
|
||||||
|
<p-dataTable
|
||||||
|
[value]="following" [lazy]="true" [paginator]="true" [totalRecords]="totalRecords" [rows]="rowsPerPage"
|
||||||
|
sortField="createdAt" (onLazyLoad)="loadLazy($event)"
|
||||||
|
>
|
||||||
|
<p-column field="id" header="ID"></p-column>
|
||||||
|
<p-column field="host" header="Host"></p-column>
|
||||||
|
<p-column field="email" header="Email"></p-column>
|
||||||
|
<p-column field="score" header="Score"></p-column>
|
||||||
|
<p-column field="createdAt" header="Created date" [sortable]="true"></p-column>
|
||||||
|
</p-dataTable>
|
||||||
|
</div>
|
||||||
|
</div>
|
|
@ -0,0 +1,40 @@
|
||||||
|
import { Component, OnInit } from '@angular/core'
|
||||||
|
|
||||||
|
import { NotificationsService } from 'angular2-notifications'
|
||||||
|
import { SortMeta } from 'primeng/primeng'
|
||||||
|
|
||||||
|
import { ConfirmService } from '../../../core'
|
||||||
|
import { RestTable, RestPagination } from '../../../shared'
|
||||||
|
import { Pod } from '../../../../../../shared'
|
||||||
|
import { FollowService } from '../shared'
|
||||||
|
|
||||||
|
@Component({
|
||||||
|
selector: 'my-followers-list',
|
||||||
|
templateUrl: './following-list.component.html'
|
||||||
|
})
|
||||||
|
export class FollowingListComponent extends RestTable {
|
||||||
|
following: Pod[] = []
|
||||||
|
totalRecords = 0
|
||||||
|
rowsPerPage = 10
|
||||||
|
sort: SortMeta = { field: 'createdAt', order: 1 }
|
||||||
|
pagination: RestPagination = { count: this.rowsPerPage, start: 0 }
|
||||||
|
|
||||||
|
constructor (
|
||||||
|
private notificationsService: NotificationsService,
|
||||||
|
private followService: FollowService
|
||||||
|
) {
|
||||||
|
super()
|
||||||
|
}
|
||||||
|
|
||||||
|
protected loadData () {
|
||||||
|
this.followService.getFollowing(this.pagination, this.sort)
|
||||||
|
.subscribe(
|
||||||
|
resultList => {
|
||||||
|
this.following = resultList.data
|
||||||
|
this.totalRecords = resultList.total
|
||||||
|
},
|
||||||
|
|
||||||
|
err => this.notificationsService.error('Error', err.message)
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1 @@
|
||||||
|
export * from './following-list.component'
|
|
@ -0,0 +1,11 @@
|
||||||
|
<div class="follows-menu">
|
||||||
|
<tabset #followsMenuTabs>
|
||||||
|
<tab *ngFor="let link of links">
|
||||||
|
<ng-template tabHeading>
|
||||||
|
<a class="tab-link" [routerLink]="link.path">{{ link.title }}</a>
|
||||||
|
</ng-template>
|
||||||
|
</tab>
|
||||||
|
</tabset>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<router-outlet></router-outlet>
|
|
@ -0,0 +1,21 @@
|
||||||
|
.follows-menu {
|
||||||
|
margin-top: 20px;
|
||||||
|
}
|
||||||
|
|
||||||
|
tabset /deep/ {
|
||||||
|
.nav-link {
|
||||||
|
padding: 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
.tab-link {
|
||||||
|
display: block;
|
||||||
|
text-align: center;
|
||||||
|
height: 40px;
|
||||||
|
width: 120px;
|
||||||
|
line-height: 40px;
|
||||||
|
|
||||||
|
&:hover, &:active, &:focus {
|
||||||
|
text-decoration: none !important;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,43 @@
|
||||||
|
import { AfterViewInit, Component, ViewChild } from '@angular/core'
|
||||||
|
import { TabsetComponent } from 'ngx-bootstrap/tabs'
|
||||||
|
|
||||||
|
@Component({
|
||||||
|
templateUrl: './follows.component.html',
|
||||||
|
styleUrls: [ './follows.component.scss' ]
|
||||||
|
})
|
||||||
|
export class FollowsComponent implements AfterViewInit {
|
||||||
|
@ViewChild('followsMenuTabs') followsMenuTabs: TabsetComponent
|
||||||
|
|
||||||
|
links = [
|
||||||
|
{
|
||||||
|
path: 'following-list',
|
||||||
|
title: 'Following'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
path: 'following-add',
|
||||||
|
title: 'Follow'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
path: 'followers-list',
|
||||||
|
title: 'Followers'
|
||||||
|
}
|
||||||
|
]
|
||||||
|
|
||||||
|
ngAfterViewInit () {
|
||||||
|
// Avoid issue with change detector
|
||||||
|
setTimeout(() => this.updateActiveTab())
|
||||||
|
}
|
||||||
|
|
||||||
|
private updateActiveTab () {
|
||||||
|
const url = window.location.pathname
|
||||||
|
|
||||||
|
for (let i = 0; i < this.links.length; i++) {
|
||||||
|
const path = this.links[i].path
|
||||||
|
|
||||||
|
if (url.endsWith(path) === true) {
|
||||||
|
this.followsMenuTabs.tabs[i].active = true
|
||||||
|
return
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,53 @@
|
||||||
|
import { Routes } from '@angular/router'
|
||||||
|
|
||||||
|
import { UserRightGuard } from '../../core'
|
||||||
|
import { FollowsComponent } from './follows.component'
|
||||||
|
import { FollowingAddComponent } from './following-add'
|
||||||
|
import { FollowersListComponent } from './followers-list'
|
||||||
|
import { UserRight } from '../../../../../shared'
|
||||||
|
import { FollowingListComponent } from './following-list/following-list.component'
|
||||||
|
|
||||||
|
export const FollowsRoutes: Routes = [
|
||||||
|
{
|
||||||
|
path: 'follows',
|
||||||
|
component: FollowsComponent,
|
||||||
|
canActivate: [ UserRightGuard ],
|
||||||
|
data: {
|
||||||
|
userRight: UserRight.MANAGE_APPLICATION_FOLLOW
|
||||||
|
},
|
||||||
|
children: [
|
||||||
|
{
|
||||||
|
path: '',
|
||||||
|
redirectTo: 'following-list',
|
||||||
|
pathMatch: 'full'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
path: 'following-list',
|
||||||
|
component: FollowingListComponent,
|
||||||
|
data: {
|
||||||
|
meta: {
|
||||||
|
title: 'Following list'
|
||||||
|
}
|
||||||
|
}
|
||||||
|
},
|
||||||
|
{
|
||||||
|
path: 'followers-list',
|
||||||
|
component: FollowersListComponent,
|
||||||
|
data: {
|
||||||
|
meta: {
|
||||||
|
title: 'Followers list'
|
||||||
|
}
|
||||||
|
}
|
||||||
|
},
|
||||||
|
{
|
||||||
|
path: 'following-add',
|
||||||
|
component: FollowingAddComponent,
|
||||||
|
data: {
|
||||||
|
meta: {
|
||||||
|
title: 'Add follow'
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
]
|
|
@ -0,0 +1,6 @@
|
||||||
|
export * from './following-add'
|
||||||
|
export * from './followers-list'
|
||||||
|
export * from './following-list'
|
||||||
|
export * from './shared'
|
||||||
|
export * from './follows.component'
|
||||||
|
export * from './follows.routes'
|
|
@ -10,8 +10,8 @@ import { RestExtractor, RestPagination, RestService } from '../../../shared'
|
||||||
import { Pod, ResultList } from '../../../../../../shared'
|
import { Pod, ResultList } from '../../../../../../shared'
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class FriendService {
|
export class FollowService {
|
||||||
private static BASE_FRIEND_URL = API_URL + '/api/v1/pods/'
|
private static BASE_APPLICATION_URL = API_URL + '/api/v1/application'
|
||||||
|
|
||||||
constructor (
|
constructor (
|
||||||
private authHttp: HttpClient,
|
private authHttp: HttpClient,
|
||||||
|
@ -23,7 +23,16 @@ export class FriendService {
|
||||||
let params = new HttpParams()
|
let params = new HttpParams()
|
||||||
params = this.restService.addRestGetParams(params, pagination, sort)
|
params = this.restService.addRestGetParams(params, pagination, sort)
|
||||||
|
|
||||||
return this.authHttp.get<ResultList<Account>>(API_URL + '/api/v1/pods/followers', { params })
|
return this.authHttp.get<ResultList<Account>>(FollowService.BASE_APPLICATION_URL + '/following', { params })
|
||||||
|
.map(res => this.restExtractor.convertResultListDateToHuman(res))
|
||||||
|
.catch(res => this.restExtractor.handleError(res))
|
||||||
|
}
|
||||||
|
|
||||||
|
getFollowers (pagination: RestPagination, sort: SortMeta): Observable<ResultList<Pod>> {
|
||||||
|
let params = new HttpParams()
|
||||||
|
params = this.restService.addRestGetParams(params, pagination, sort)
|
||||||
|
|
||||||
|
return this.authHttp.get<ResultList<Account>>(FollowService.BASE_APPLICATION_URL + '/followers', { params })
|
||||||
.map(res => this.restExtractor.convertResultListDateToHuman(res))
|
.map(res => this.restExtractor.convertResultListDateToHuman(res))
|
||||||
.catch(res => this.restExtractor.handleError(res))
|
.catch(res => this.restExtractor.handleError(res))
|
||||||
}
|
}
|
||||||
|
@ -33,19 +42,7 @@ export class FriendService {
|
||||||
hosts: notEmptyHosts
|
hosts: notEmptyHosts
|
||||||
}
|
}
|
||||||
|
|
||||||
return this.authHttp.post(API_URL + '/api/v1/pods/follow', body)
|
return this.authHttp.post(FollowService.BASE_APPLICATION_URL + '/follow', body)
|
||||||
.map(this.restExtractor.extractDataBool)
|
|
||||||
.catch(res => this.restExtractor.handleError(res))
|
|
||||||
}
|
|
||||||
|
|
||||||
quitFriends () {
|
|
||||||
return this.authHttp.get(FriendService.BASE_FRIEND_URL + 'quit-friends')
|
|
||||||
.map(this.restExtractor.extractDataBool)
|
|
||||||
.catch(res => this.restExtractor.handleError(res))
|
|
||||||
}
|
|
||||||
|
|
||||||
removeFriend (friend: Pod) {
|
|
||||||
return this.authHttp.delete(FriendService.BASE_FRIEND_URL + friend.id)
|
|
||||||
.map(this.restExtractor.extractDataBool)
|
.map(this.restExtractor.extractDataBool)
|
||||||
.catch(res => this.restExtractor.handleError(res))
|
.catch(res => this.restExtractor.handleError(res))
|
||||||
}
|
}
|
|
@ -0,0 +1 @@
|
||||||
|
export * from './follow.service'
|
|
@ -1 +0,0 @@
|
||||||
export * from './friend-add.component'
|
|
|
@ -1,29 +0,0 @@
|
||||||
<div class="row">
|
|
||||||
<div class="content-padding">
|
|
||||||
<h3>Friends list</h3>
|
|
||||||
|
|
||||||
<p-dataTable
|
|
||||||
[value]="friends" [lazy]="true" [paginator]="true" [totalRecords]="totalRecords" [rows]="rowsPerPage"
|
|
||||||
sortField="createdAt" (onLazyLoad)="loadLazy($event)"
|
|
||||||
>
|
|
||||||
<p-column field="id" header="ID"></p-column>
|
|
||||||
<p-column field="host" header="Host"></p-column>
|
|
||||||
<p-column field="email" header="Email"></p-column>
|
|
||||||
<p-column field="score" header="Score"></p-column>
|
|
||||||
<p-column field="createdAt" header="Created date" [sortable]="true"></p-column>
|
|
||||||
<p-column header="Delete" styleClass="action-cell">
|
|
||||||
<ng-template pTemplate="body" let-pod="rowData">
|
|
||||||
<span (click)="removeFriend(pod)" class="glyphicon glyphicon-remove glyphicon-black" title="Remove this pod"></span>
|
|
||||||
</ng-template>
|
|
||||||
</p-column>
|
|
||||||
</p-dataTable>
|
|
||||||
|
|
||||||
<a *ngIf="hasFriends()" class="btn btn-danger pull-left" (click)="quitFriends()">
|
|
||||||
Quit friends
|
|
||||||
</a>
|
|
||||||
|
|
||||||
<a *ngIf="!hasFriends()" class="btn btn-success pull-right" [routerLink]="[ '/admin/friends/add' ]">
|
|
||||||
Make friends
|
|
||||||
</a>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
|
@ -1,87 +0,0 @@
|
||||||
import { Component, OnInit } from '@angular/core'
|
|
||||||
|
|
||||||
import { NotificationsService } from 'angular2-notifications'
|
|
||||||
import { SortMeta } from 'primeng/primeng'
|
|
||||||
|
|
||||||
import { ConfirmService } from '../../../core'
|
|
||||||
import { RestTable, RestPagination } from '../../../shared'
|
|
||||||
import { Pod } from '../../../../../../shared'
|
|
||||||
import { FriendService } from '../shared'
|
|
||||||
|
|
||||||
@Component({
|
|
||||||
selector: 'my-friend-list',
|
|
||||||
templateUrl: './friend-list.component.html',
|
|
||||||
styleUrls: ['./friend-list.component.scss']
|
|
||||||
})
|
|
||||||
export class FriendListComponent extends RestTable implements OnInit {
|
|
||||||
friends: Pod[] = []
|
|
||||||
totalRecords = 0
|
|
||||||
rowsPerPage = 10
|
|
||||||
sort: SortMeta = { field: 'createdAt', order: 1 }
|
|
||||||
pagination: RestPagination = { count: this.rowsPerPage, start: 0 }
|
|
||||||
|
|
||||||
constructor (
|
|
||||||
private notificationsService: NotificationsService,
|
|
||||||
private confirmService: ConfirmService,
|
|
||||||
private friendService: FriendService
|
|
||||||
) {
|
|
||||||
super()
|
|
||||||
}
|
|
||||||
|
|
||||||
ngOnInit () {
|
|
||||||
this.loadData()
|
|
||||||
}
|
|
||||||
|
|
||||||
hasFriends () {
|
|
||||||
return this.friends.length !== 0
|
|
||||||
}
|
|
||||||
|
|
||||||
quitFriends () {
|
|
||||||
const confirmMessage = 'Do you really want to quit your friends? All their videos will be deleted.'
|
|
||||||
this.confirmService.confirm(confirmMessage, 'Quit friends').subscribe(
|
|
||||||
res => {
|
|
||||||
if (res === false) return
|
|
||||||
|
|
||||||
this.friendService.quitFriends().subscribe(
|
|
||||||
status => {
|
|
||||||
this.notificationsService.success('Success', 'Friends left!')
|
|
||||||
this.loadData()
|
|
||||||
},
|
|
||||||
|
|
||||||
err => this.notificationsService.error('Error', err.message)
|
|
||||||
)
|
|
||||||
}
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
removeFriend (friend: Pod) {
|
|
||||||
const confirmMessage = 'Do you really want to remove this friend ? All its videos will be deleted.'
|
|
||||||
|
|
||||||
this.confirmService.confirm(confirmMessage, 'Remove').subscribe(
|
|
||||||
res => {
|
|
||||||
if (res === false) return
|
|
||||||
|
|
||||||
this.friendService.removeFriend(friend).subscribe(
|
|
||||||
status => {
|
|
||||||
this.notificationsService.success('Success', 'Friend removed')
|
|
||||||
this.loadData()
|
|
||||||
},
|
|
||||||
|
|
||||||
err => this.notificationsService.error('Error', err.message)
|
|
||||||
)
|
|
||||||
}
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
protected loadData () {
|
|
||||||
this.friendService.getFollowing(this.pagination, this.sort)
|
|
||||||
.subscribe(
|
|
||||||
resultList => {
|
|
||||||
this.friends = resultList.data
|
|
||||||
this.totalRecords = resultList.total
|
|
||||||
},
|
|
||||||
|
|
||||||
err => this.notificationsService.error('Error', err.message)
|
|
||||||
)
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1 +0,0 @@
|
||||||
export * from './friend-list.component'
|
|
|
@ -1,7 +0,0 @@
|
||||||
import { Component } from '@angular/core'
|
|
||||||
|
|
||||||
@Component({
|
|
||||||
template: '<router-outlet></router-outlet>'
|
|
||||||
})
|
|
||||||
export class FriendsComponent {
|
|
||||||
}
|
|
|
@ -1,43 +0,0 @@
|
||||||
import { Routes } from '@angular/router'
|
|
||||||
|
|
||||||
import { UserRightGuard } from '../../core'
|
|
||||||
import { FriendsComponent } from './friends.component'
|
|
||||||
import { FriendAddComponent } from './friend-add'
|
|
||||||
import { FriendListComponent } from './friend-list'
|
|
||||||
import { UserRight } from '../../../../../shared'
|
|
||||||
|
|
||||||
export const FriendsRoutes: Routes = [
|
|
||||||
{
|
|
||||||
path: 'friends',
|
|
||||||
component: FriendsComponent,
|
|
||||||
canActivate: [ UserRightGuard ],
|
|
||||||
data: {
|
|
||||||
userRight: UserRight.MANAGE_PEERTUBE_FOLLOW
|
|
||||||
},
|
|
||||||
children: [
|
|
||||||
{
|
|
||||||
path: '',
|
|
||||||
redirectTo: 'list',
|
|
||||||
pathMatch: 'full'
|
|
||||||
},
|
|
||||||
{
|
|
||||||
path: 'list',
|
|
||||||
component: FriendListComponent,
|
|
||||||
data: {
|
|
||||||
meta: {
|
|
||||||
title: 'Friends list'
|
|
||||||
}
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
path: 'add',
|
|
||||||
component: FriendAddComponent,
|
|
||||||
data: {
|
|
||||||
meta: {
|
|
||||||
title: 'Add friends'
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
]
|
|
|
@ -1,5 +0,0 @@
|
||||||
export * from './friend-add'
|
|
||||||
export * from './friend-list'
|
|
||||||
export * from './shared'
|
|
||||||
export * from './friends.component'
|
|
||||||
export * from './friends.routes'
|
|
|
@ -1 +0,0 @@
|
||||||
export * from './friend.service'
|
|
|
@ -5,9 +5,9 @@
|
||||||
List users
|
List users
|
||||||
</a>
|
</a>
|
||||||
|
|
||||||
<a *ngIf="hasFriendsRight()" routerLink="/admin/friends" routerLinkActive="active">
|
<a *ngIf="hasApplicationFollowRight()" routerLink="/admin/follows" routerLinkActive="active">
|
||||||
<span class="hidden-xs glyphicon glyphicon-cloud"></span>
|
<span class="hidden-xs glyphicon glyphicon-cloud"></span>
|
||||||
List friends
|
Manage follows
|
||||||
</a>
|
</a>
|
||||||
|
|
||||||
<a *ngIf="hasVideoAbusesRight()" routerLink="/admin/video-abuses" routerLinkActive="active">
|
<a *ngIf="hasVideoAbusesRight()" routerLink="/admin/video-abuses" routerLinkActive="active">
|
||||||
|
|
|
@ -15,8 +15,8 @@ export class MenuAdminComponent {
|
||||||
return this.auth.getUser().hasRight(UserRight.MANAGE_USERS)
|
return this.auth.getUser().hasRight(UserRight.MANAGE_USERS)
|
||||||
}
|
}
|
||||||
|
|
||||||
hasFriendsRight () {
|
hasApplicationFollowRight () {
|
||||||
return this.auth.getUser().hasRight(UserRight.MANAGE_PEERTUBE_FOLLOW)
|
return this.auth.getUser().hasRight(UserRight.MANAGE_APPLICATION_FOLLOW)
|
||||||
}
|
}
|
||||||
|
|
||||||
hasVideoAbusesRight () {
|
hasVideoAbusesRight () {
|
||||||
|
|
|
@ -16,7 +16,7 @@ export class MenuComponent implements OnInit {
|
||||||
|
|
||||||
private routesPerRight = {
|
private routesPerRight = {
|
||||||
[UserRight.MANAGE_USERS]: '/admin/users',
|
[UserRight.MANAGE_USERS]: '/admin/users',
|
||||||
[UserRight.MANAGE_PEERTUBE_FOLLOW]: '/admin/friends',
|
[UserRight.MANAGE_APPLICATION_FOLLOW]: '/admin/friends',
|
||||||
[UserRight.MANAGE_VIDEO_ABUSES]: '/admin/video-abuses',
|
[UserRight.MANAGE_VIDEO_ABUSES]: '/admin/video-abuses',
|
||||||
[UserRight.MANAGE_VIDEO_BLACKLIST]: '/admin/video-blacklist'
|
[UserRight.MANAGE_VIDEO_BLACKLIST]: '/admin/video-blacklist'
|
||||||
}
|
}
|
||||||
|
@ -58,7 +58,7 @@ export class MenuComponent implements OnInit {
|
||||||
|
|
||||||
const adminRights = [
|
const adminRights = [
|
||||||
UserRight.MANAGE_USERS,
|
UserRight.MANAGE_USERS,
|
||||||
UserRight.MANAGE_PEERTUBE_FOLLOW,
|
UserRight.MANAGE_APPLICATION_FOLLOW,
|
||||||
UserRight.MANAGE_VIDEO_ABUSES,
|
UserRight.MANAGE_VIDEO_ABUSES,
|
||||||
UserRight.MANAGE_VIDEO_BLACKLIST
|
UserRight.MANAGE_VIDEO_BLACKLIST
|
||||||
]
|
]
|
||||||
|
|
|
@ -3,7 +3,7 @@ import { database as db } from '../server/initializers/database'
|
||||||
|
|
||||||
db.init(true)
|
db.init(true)
|
||||||
.then(() => {
|
.then(() => {
|
||||||
// FIXME: check if has followers
|
// FIXME: check if has following
|
||||||
// return hasFriends()
|
// return hasFriends()
|
||||||
return true
|
return true
|
||||||
})
|
})
|
||||||
|
|
|
@ -46,7 +46,7 @@ async function accountFollowersController (req: express.Request, res: express.Re
|
||||||
const page = req.params.page || 1
|
const page = req.params.page || 1
|
||||||
const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE)
|
const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE)
|
||||||
|
|
||||||
const result = await db.Account.listAcceptedFollowerUrlsForApi(account.id, start, count)
|
const result = await db.AccountFollow.listAcceptedFollowerUrlsForApi(account.id, start, count)
|
||||||
const activityPubResult = activityPubCollectionPagination(req.url, page, result)
|
const activityPubResult = activityPubCollectionPagination(req.url, page, result)
|
||||||
|
|
||||||
return res.json(activityPubResult)
|
return res.json(activityPubResult)
|
||||||
|
@ -58,7 +58,7 @@ async function accountFollowingController (req: express.Request, res: express.Re
|
||||||
const page = req.params.page || 1
|
const page = req.params.page || 1
|
||||||
const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE)
|
const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE)
|
||||||
|
|
||||||
const result = await db.Account.listAcceptedFollowingUrlsForApi(account.id, start, count)
|
const result = await db.AccountFollow.listAcceptedFollowingUrlsForApi(account.id, start, count)
|
||||||
const activityPubResult = activityPubCollectionPagination(req.url, page, result)
|
const activityPubResult = activityPubCollectionPagination(req.url, page, result)
|
||||||
|
|
||||||
return res.json(activityPubResult)
|
return res.json(activityPubResult)
|
||||||
|
|
|
@ -1,14 +1,11 @@
|
||||||
import * as express from 'express'
|
import * as express from 'express'
|
||||||
|
|
||||||
import { badRequest } from '../../helpers'
|
|
||||||
import { inboxRouter } from './inbox'
|
|
||||||
import { activityPubClientRouter } from './client'
|
import { activityPubClientRouter } from './client'
|
||||||
|
import { inboxRouter } from './inbox'
|
||||||
|
|
||||||
const activityPubRouter = express.Router()
|
const activityPubRouter = express.Router()
|
||||||
|
|
||||||
activityPubRouter.use('/', inboxRouter)
|
activityPubRouter.use('/', inboxRouter)
|
||||||
activityPubRouter.use('/', activityPubClientRouter)
|
activityPubRouter.use('/', activityPubClientRouter)
|
||||||
activityPubRouter.use('/*', badRequest)
|
|
||||||
|
|
||||||
// ---------------------------------------------------------------------------
|
// ---------------------------------------------------------------------------
|
||||||
|
|
||||||
|
|
|
@ -1,23 +1,23 @@
|
||||||
import * as express from 'express'
|
import * as express from 'express'
|
||||||
import { UserRight } from '../../../shared/models/users/user-right.enum'
|
import { UserRight } from '../../../../shared/models/users/user-right.enum'
|
||||||
import { getFormattedObjects } from '../../helpers'
|
import { getFormattedObjects } from '../../../helpers'
|
||||||
import { logger } from '../../helpers/logger'
|
import { logger } from '../../../helpers/logger'
|
||||||
import { getApplicationAccount } from '../../helpers/utils'
|
import { getApplicationAccount } from '../../../helpers/utils'
|
||||||
import { getAccountFromWebfinger } from '../../helpers/webfinger'
|
import { getAccountFromWebfinger } from '../../../helpers/webfinger'
|
||||||
import { SERVER_ACCOUNT_NAME } from '../../initializers/constants'
|
import { SERVER_ACCOUNT_NAME } from '../../../initializers/constants'
|
||||||
import { database as db } from '../../initializers/database'
|
import { database as db } from '../../../initializers/database'
|
||||||
import { sendFollow } from '../../lib/activitypub/send-request'
|
import { sendFollow } from '../../../lib/activitypub/send-request'
|
||||||
import { asyncMiddleware, paginationValidator, setFollowersSort, setPagination } from '../../middlewares'
|
import { asyncMiddleware, paginationValidator, setFollowersSort, setPagination } from '../../../middlewares'
|
||||||
import { authenticate } from '../../middlewares/oauth'
|
import { authenticate } from '../../../middlewares/oauth'
|
||||||
import { setBodyHostsPort } from '../../middlewares/pods'
|
import { setBodyHostsPort } from '../../../middlewares/pods'
|
||||||
import { setFollowingSort } from '../../middlewares/sort'
|
import { setFollowingSort } from '../../../middlewares/sort'
|
||||||
import { ensureUserHasRight } from '../../middlewares/user-right'
|
import { ensureUserHasRight } from '../../../middlewares/user-right'
|
||||||
import { followValidator } from '../../middlewares/validators/pods'
|
import { followValidator } from '../../../middlewares/validators/pods'
|
||||||
import { followersSortValidator, followingSortValidator } from '../../middlewares/validators/sort'
|
import { followersSortValidator, followingSortValidator } from '../../../middlewares/validators/sort'
|
||||||
|
|
||||||
const podsRouter = express.Router()
|
const applicationFollowsRouter = express.Router()
|
||||||
|
|
||||||
podsRouter.get('/following',
|
applicationFollowsRouter.get('/following',
|
||||||
paginationValidator,
|
paginationValidator,
|
||||||
followingSortValidator,
|
followingSortValidator,
|
||||||
setFollowingSort,
|
setFollowingSort,
|
||||||
|
@ -25,15 +25,15 @@ podsRouter.get('/following',
|
||||||
asyncMiddleware(listFollowing)
|
asyncMiddleware(listFollowing)
|
||||||
)
|
)
|
||||||
|
|
||||||
podsRouter.post('/follow',
|
applicationFollowsRouter.post('/follow',
|
||||||
authenticate,
|
authenticate,
|
||||||
ensureUserHasRight(UserRight.MANAGE_PEERTUBE_FOLLOW),
|
ensureUserHasRight(UserRight.MANAGE_APPLICATION_FOLLOW),
|
||||||
followValidator,
|
followValidator,
|
||||||
setBodyHostsPort,
|
setBodyHostsPort,
|
||||||
asyncMiddleware(follow)
|
asyncMiddleware(follow)
|
||||||
)
|
)
|
||||||
|
|
||||||
podsRouter.get('/followers',
|
applicationFollowsRouter.get('/followers',
|
||||||
paginationValidator,
|
paginationValidator,
|
||||||
followersSortValidator,
|
followersSortValidator,
|
||||||
setFollowersSort,
|
setFollowersSort,
|
||||||
|
@ -44,21 +44,21 @@ podsRouter.get('/followers',
|
||||||
// ---------------------------------------------------------------------------
|
// ---------------------------------------------------------------------------
|
||||||
|
|
||||||
export {
|
export {
|
||||||
podsRouter
|
applicationFollowsRouter
|
||||||
}
|
}
|
||||||
|
|
||||||
// ---------------------------------------------------------------------------
|
// ---------------------------------------------------------------------------
|
||||||
|
|
||||||
async function listFollowing (req: express.Request, res: express.Response, next: express.NextFunction) {
|
async function listFollowing (req: express.Request, res: express.Response, next: express.NextFunction) {
|
||||||
const applicationAccount = await getApplicationAccount()
|
const applicationAccount = await getApplicationAccount()
|
||||||
const resultList = await db.Account.listFollowingForApi(applicationAccount.id, req.query.start, req.query.count, req.query.sort)
|
const resultList = await db.AccountFollow.listFollowingForApi(applicationAccount.id, req.query.start, req.query.count, req.query.sort)
|
||||||
|
|
||||||
return res.json(getFormattedObjects(resultList.data, resultList.total))
|
return res.json(getFormattedObjects(resultList.data, resultList.total))
|
||||||
}
|
}
|
||||||
|
|
||||||
async function listFollowers (req: express.Request, res: express.Response, next: express.NextFunction) {
|
async function listFollowers (req: express.Request, res: express.Response, next: express.NextFunction) {
|
||||||
const applicationAccount = await getApplicationAccount()
|
const applicationAccount = await getApplicationAccount()
|
||||||
const resultList = await db.Account.listFollowersForApi(applicationAccount.id, req.query.start, req.query.count, req.query.sort)
|
const resultList = await db.AccountFollow.listFollowersForApi(applicationAccount.id, req.query.start, req.query.count, req.query.sort)
|
||||||
|
|
||||||
return res.json(getFormattedObjects(resultList.data, resultList.total))
|
return res.json(getFormattedObjects(resultList.data, resultList.total))
|
||||||
}
|
}
|
|
@ -0,0 +1,12 @@
|
||||||
|
import * as express from 'express'
|
||||||
|
import { applicationFollowsRouter } from './follows'
|
||||||
|
|
||||||
|
const applicationRouter = express.Router()
|
||||||
|
|
||||||
|
applicationRouter.use('/', applicationFollowsRouter)
|
||||||
|
|
||||||
|
// ---------------------------------------------------------------------------
|
||||||
|
|
||||||
|
export {
|
||||||
|
applicationRouter
|
||||||
|
}
|
|
@ -4,15 +4,15 @@ import { badRequest } from '../../helpers'
|
||||||
|
|
||||||
import { oauthClientsRouter } from './oauth-clients'
|
import { oauthClientsRouter } from './oauth-clients'
|
||||||
import { configRouter } from './config'
|
import { configRouter } from './config'
|
||||||
import { podsRouter } from './pods'
|
import { applicationRouter } from './application'
|
||||||
import { usersRouter } from './users'
|
import { usersRouter } from './users'
|
||||||
import { videosRouter } from './videos'
|
import { videosRouter } from './videos'
|
||||||
|
|
||||||
const apiRouter = express.Router()
|
const apiRouter = express.Router()
|
||||||
|
|
||||||
|
apiRouter.use('/application', applicationRouter)
|
||||||
apiRouter.use('/oauth-clients', oauthClientsRouter)
|
apiRouter.use('/oauth-clients', oauthClientsRouter)
|
||||||
apiRouter.use('/config', configRouter)
|
apiRouter.use('/config', configRouter)
|
||||||
apiRouter.use('/pods', podsRouter)
|
|
||||||
apiRouter.use('/users', usersRouter)
|
apiRouter.use('/users', usersRouter)
|
||||||
apiRouter.use('/videos', videosRouter)
|
apiRouter.use('/videos', videosRouter)
|
||||||
apiRouter.use('/ping', pong)
|
apiRouter.use('/ping', pong)
|
||||||
|
|
|
@ -8,7 +8,7 @@ import { AccountInstance } from '../models/account/account-interface'
|
||||||
|
|
||||||
const webfingerRouter = express.Router()
|
const webfingerRouter = express.Router()
|
||||||
|
|
||||||
webfingerRouter.use('/.well-known/webfinger',
|
webfingerRouter.get('/.well-known/webfinger',
|
||||||
webfingerValidator,
|
webfingerValidator,
|
||||||
webfingerController
|
webfingerController
|
||||||
)
|
)
|
||||||
|
|
|
@ -85,7 +85,7 @@ export {
|
||||||
// ---------------------------------------------------------------------------
|
// ---------------------------------------------------------------------------
|
||||||
|
|
||||||
async function broadcastToFollowers (data: any, fromAccount: AccountInstance, t: Sequelize.Transaction) {
|
async function broadcastToFollowers (data: any, fromAccount: AccountInstance, t: Sequelize.Transaction) {
|
||||||
const result = await db.Account.listAcceptedFollowerUrlsForApi(fromAccount.id, 0)
|
const result = await db.AccountFollow.listAcceptedFollowerUrlsForApi(fromAccount.id, 0)
|
||||||
|
|
||||||
const jobPayload = {
|
const jobPayload = {
|
||||||
uris: result.data,
|
uris: result.data,
|
||||||
|
|
|
@ -1,13 +1,26 @@
|
||||||
import * as Sequelize from 'sequelize'
|
import * as Sequelize from 'sequelize'
|
||||||
import * as Bluebird from 'bluebird'
|
import * as Bluebird from 'bluebird'
|
||||||
import { FollowState } from '../../../shared/models/accounts/follow.model'
|
import { FollowState } from '../../../shared/models/accounts/follow.model'
|
||||||
|
import { ResultList } from '../../../shared/models/result-list.model'
|
||||||
|
import { AccountInstance } from './account-interface'
|
||||||
|
|
||||||
export namespace AccountFollowMethods {
|
export namespace AccountFollowMethods {
|
||||||
export type LoadByAccountAndTarget = (accountId: number, targetAccountId: number) => Bluebird<AccountFollowInstance>
|
export type LoadByAccountAndTarget = (accountId: number, targetAccountId: number) => Bluebird<AccountFollowInstance>
|
||||||
|
|
||||||
|
export type ListFollowingForApi = (id: number, start: number, count: number, sort: string) => Bluebird< ResultList<AccountInstance> >
|
||||||
|
export type ListFollowersForApi = (id: number, start: number, count: number, sort: string) => Bluebird< ResultList<AccountInstance> >
|
||||||
|
|
||||||
|
export type ListAcceptedFollowerUrlsForApi = (id: number, start: number, count?: number) => Promise< ResultList<string> >
|
||||||
|
export type ListAcceptedFollowingUrlsForApi = (id: number, start: number, count?: number) => Promise< ResultList<string> >
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface AccountFollowClass {
|
export interface AccountFollowClass {
|
||||||
loadByAccountAndTarget: AccountFollowMethods.LoadByAccountAndTarget
|
loadByAccountAndTarget: AccountFollowMethods.LoadByAccountAndTarget
|
||||||
|
listFollowersForApi: AccountFollowMethods.ListFollowersForApi
|
||||||
|
listFollowingForApi: AccountFollowMethods.ListFollowingForApi
|
||||||
|
|
||||||
|
listAcceptedFollowerUrlsForApi: AccountFollowMethods.ListAcceptedFollowerUrlsForApi
|
||||||
|
listAcceptedFollowingUrlsForApi: AccountFollowMethods.ListAcceptedFollowingUrlsForApi
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface AccountFollowAttributes {
|
export interface AccountFollowAttributes {
|
||||||
|
@ -20,6 +33,9 @@ export interface AccountFollowInstance extends AccountFollowClass, AccountFollow
|
||||||
id: number
|
id: number
|
||||||
createdAt: Date
|
createdAt: Date
|
||||||
updatedAt: Date
|
updatedAt: Date
|
||||||
|
|
||||||
|
AccountFollower?: AccountInstance
|
||||||
|
AccountFollowing?: AccountInstance
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface AccountFollowModel extends AccountFollowClass, Sequelize.Model<AccountFollowInstance, AccountFollowAttributes> {}
|
export interface AccountFollowModel extends AccountFollowClass, Sequelize.Model<AccountFollowInstance, AccountFollowAttributes> {}
|
||||||
|
|
|
@ -1,12 +1,16 @@
|
||||||
import { values } from 'lodash'
|
import { values } from 'lodash'
|
||||||
import * as Sequelize from 'sequelize'
|
import * as Sequelize from 'sequelize'
|
||||||
|
|
||||||
import { addMethodsToModel } from '../utils'
|
import { addMethodsToModel, getSort } from '../utils'
|
||||||
import { AccountFollowAttributes, AccountFollowInstance, AccountFollowMethods } from './account-follow-interface'
|
import { AccountFollowAttributes, AccountFollowInstance, AccountFollowMethods } from './account-follow-interface'
|
||||||
import { FOLLOW_STATES } from '../../initializers/constants'
|
import { FOLLOW_STATES } from '../../initializers/constants'
|
||||||
|
|
||||||
let AccountFollow: Sequelize.Model<AccountFollowInstance, AccountFollowAttributes>
|
let AccountFollow: Sequelize.Model<AccountFollowInstance, AccountFollowAttributes>
|
||||||
let loadByAccountAndTarget: AccountFollowMethods.LoadByAccountAndTarget
|
let loadByAccountAndTarget: AccountFollowMethods.LoadByAccountAndTarget
|
||||||
|
let listFollowingForApi: AccountFollowMethods.ListFollowingForApi
|
||||||
|
let listFollowersForApi: AccountFollowMethods.ListFollowersForApi
|
||||||
|
let listAcceptedFollowerUrlsForApi: AccountFollowMethods.ListAcceptedFollowerUrlsForApi
|
||||||
|
let listAcceptedFollowingUrlsForApi: AccountFollowMethods.ListAcceptedFollowingUrlsForApi
|
||||||
|
|
||||||
export default function (sequelize: Sequelize.Sequelize, DataTypes: Sequelize.DataTypes) {
|
export default function (sequelize: Sequelize.Sequelize, DataTypes: Sequelize.DataTypes) {
|
||||||
AccountFollow = sequelize.define<AccountFollowInstance, AccountFollowAttributes>('AccountFollow',
|
AccountFollow = sequelize.define<AccountFollowInstance, AccountFollowAttributes>('AccountFollow',
|
||||||
|
@ -34,7 +38,11 @@ export default function (sequelize: Sequelize.Sequelize, DataTypes: Sequelize.Da
|
||||||
|
|
||||||
const classMethods = [
|
const classMethods = [
|
||||||
associate,
|
associate,
|
||||||
loadByAccountAndTarget
|
loadByAccountAndTarget,
|
||||||
|
listFollowingForApi,
|
||||||
|
listFollowersForApi,
|
||||||
|
listAcceptedFollowerUrlsForApi,
|
||||||
|
listAcceptedFollowingUrlsForApi
|
||||||
]
|
]
|
||||||
addMethodsToModel(AccountFollow, classMethods)
|
addMethodsToModel(AccountFollow, classMethods)
|
||||||
|
|
||||||
|
@ -49,7 +57,7 @@ function associate (models) {
|
||||||
name: 'accountId',
|
name: 'accountId',
|
||||||
allowNull: false
|
allowNull: false
|
||||||
},
|
},
|
||||||
as: 'accountFollowers',
|
as: 'AccountFollower',
|
||||||
onDelete: 'CASCADE'
|
onDelete: 'CASCADE'
|
||||||
})
|
})
|
||||||
|
|
||||||
|
@ -58,7 +66,7 @@ function associate (models) {
|
||||||
name: 'targetAccountId',
|
name: 'targetAccountId',
|
||||||
allowNull: false
|
allowNull: false
|
||||||
},
|
},
|
||||||
as: 'accountFollowing',
|
as: 'AccountFollowing',
|
||||||
onDelete: 'CASCADE'
|
onDelete: 'CASCADE'
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
@ -73,3 +81,117 @@ loadByAccountAndTarget = function (accountId: number, targetAccountId: number) {
|
||||||
|
|
||||||
return AccountFollow.findOne(query)
|
return AccountFollow.findOne(query)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
listFollowingForApi = function (id: number, start: number, count: number, sort: string) {
|
||||||
|
const query = {
|
||||||
|
distinct: true,
|
||||||
|
offset: start,
|
||||||
|
limit: count,
|
||||||
|
order: [ getSort(sort) ],
|
||||||
|
include: [
|
||||||
|
{
|
||||||
|
model: AccountFollow[ 'sequelize' ].models.Account,
|
||||||
|
required: true,
|
||||||
|
as: 'AccountFollower',
|
||||||
|
where: {
|
||||||
|
id
|
||||||
|
}
|
||||||
|
},
|
||||||
|
{
|
||||||
|
model: AccountFollow['sequelize'].models.Account,
|
||||||
|
as: 'AccountFollowing',
|
||||||
|
required: true,
|
||||||
|
include: [ AccountFollow['sequelize'].models.Pod ]
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
|
||||||
|
return AccountFollow.findAndCountAll(query).then(({ rows, count }) => {
|
||||||
|
return {
|
||||||
|
data: rows.map(r => r.AccountFollowing),
|
||||||
|
total: count
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
listFollowersForApi = function (id: number, start: number, count: number, sort: string) {
|
||||||
|
const query = {
|
||||||
|
distinct: true,
|
||||||
|
offset: start,
|
||||||
|
limit: count,
|
||||||
|
order: [ getSort(sort) ],
|
||||||
|
include: [
|
||||||
|
{
|
||||||
|
model: AccountFollow[ 'sequelize' ].models.Account,
|
||||||
|
required: true,
|
||||||
|
as: 'AccountFollower',
|
||||||
|
include: [ AccountFollow['sequelize'].models.Pod ]
|
||||||
|
},
|
||||||
|
{
|
||||||
|
model: AccountFollow['sequelize'].models.Account,
|
||||||
|
as: 'AccountFollowing',
|
||||||
|
required: true,
|
||||||
|
where: {
|
||||||
|
id
|
||||||
|
}
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
|
||||||
|
return AccountFollow.findAndCountAll(query).then(({ rows, count }) => {
|
||||||
|
return {
|
||||||
|
data: rows.map(r => r.AccountFollower),
|
||||||
|
total: count
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
listAcceptedFollowerUrlsForApi = function (id: number, start: number, count?: number) {
|
||||||
|
return createListAcceptedFollowForApiQuery('followers', id, start, count)
|
||||||
|
}
|
||||||
|
|
||||||
|
listAcceptedFollowingUrlsForApi = function (id: number, start: number, count?: number) {
|
||||||
|
return createListAcceptedFollowForApiQuery('following', id, start, count)
|
||||||
|
}
|
||||||
|
|
||||||
|
// ------------------------------ UTILS ------------------------------
|
||||||
|
|
||||||
|
async function createListAcceptedFollowForApiQuery (type: 'followers' | 'following', id: number, start: number, count?: number) {
|
||||||
|
let firstJoin: string
|
||||||
|
let secondJoin: string
|
||||||
|
|
||||||
|
if (type === 'followers') {
|
||||||
|
firstJoin = 'targetAccountId'
|
||||||
|
secondJoin = 'accountId'
|
||||||
|
} else {
|
||||||
|
firstJoin = 'accountId'
|
||||||
|
secondJoin = 'targetAccountId'
|
||||||
|
}
|
||||||
|
|
||||||
|
const selections = [ '"Followers"."url" AS "url"', 'COUNT(*) AS "total"' ]
|
||||||
|
const tasks: Promise<any>[] = []
|
||||||
|
|
||||||
|
for (const selection of selections) {
|
||||||
|
let query = 'SELECT ' + selection + ' FROM "Account" ' +
|
||||||
|
'INNER JOIN "AccountFollow" ON "AccountFollow"."' + firstJoin + '" = "Account"."id" ' +
|
||||||
|
'INNER JOIN "Account" AS "Follows" ON "Followers"."id" = "Follows"."' + secondJoin + '" ' +
|
||||||
|
'WHERE "Account"."id" = $id AND "AccountFollow"."state" = \'accepted\' ' +
|
||||||
|
'LIMIT ' + start
|
||||||
|
|
||||||
|
if (count !== undefined) query += ', ' + count
|
||||||
|
|
||||||
|
const options = {
|
||||||
|
bind: { id },
|
||||||
|
type: Sequelize.QueryTypes.SELECT
|
||||||
|
}
|
||||||
|
tasks.push(AccountFollow['sequelize'].query(query, options))
|
||||||
|
}
|
||||||
|
|
||||||
|
const [ followers, [ { total } ]] = await Promise.all(tasks)
|
||||||
|
const urls: string[] = followers.map(f => f.url)
|
||||||
|
|
||||||
|
return {
|
||||||
|
data: urls,
|
||||||
|
total: parseInt(total, 10)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
|
@ -15,10 +15,6 @@ export namespace AccountMethods {
|
||||||
export type LoadLocalByName = (name: string) => Bluebird<AccountInstance>
|
export type LoadLocalByName = (name: string) => Bluebird<AccountInstance>
|
||||||
export type LoadByNameAndHost = (name: string, host: string) => Bluebird<AccountInstance>
|
export type LoadByNameAndHost = (name: string, host: string) => Bluebird<AccountInstance>
|
||||||
export type ListOwned = () => Bluebird<AccountInstance[]>
|
export type ListOwned = () => Bluebird<AccountInstance[]>
|
||||||
export type ListAcceptedFollowerUrlsForApi = (id: number, start: number, count?: number) => Promise< ResultList<string> >
|
|
||||||
export type ListAcceptedFollowingUrlsForApi = (id: number, start: number, count?: number) => Promise< ResultList<string> >
|
|
||||||
export type ListFollowingForApi = (id: number, start: number, count: number, sort: string) => Bluebird< ResultList<AccountInstance> >
|
|
||||||
export type ListFollowersForApi = (id: number, start: number, count: number, sort: string) => Bluebird< ResultList<AccountInstance> >
|
|
||||||
|
|
||||||
export type ToActivityPubObject = (this: AccountInstance) => ActivityPubActor
|
export type ToActivityPubObject = (this: AccountInstance) => ActivityPubActor
|
||||||
export type ToFormattedJSON = (this: AccountInstance) => FormattedAccount
|
export type ToFormattedJSON = (this: AccountInstance) => FormattedAccount
|
||||||
|
@ -38,10 +34,6 @@ export interface AccountClass {
|
||||||
loadLocalByName: AccountMethods.LoadLocalByName
|
loadLocalByName: AccountMethods.LoadLocalByName
|
||||||
loadByNameAndHost: AccountMethods.LoadByNameAndHost
|
loadByNameAndHost: AccountMethods.LoadByNameAndHost
|
||||||
listOwned: AccountMethods.ListOwned
|
listOwned: AccountMethods.ListOwned
|
||||||
listAcceptedFollowerUrlsForApi: AccountMethods.ListAcceptedFollowerUrlsForApi
|
|
||||||
listAcceptedFollowingUrlsForApi: AccountMethods.ListAcceptedFollowingUrlsForApi
|
|
||||||
listFollowingForApi: AccountMethods.ListFollowingForApi
|
|
||||||
listFollowersForApi: AccountMethods.ListFollowersForApi
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface AccountAttributes {
|
export interface AccountAttributes {
|
||||||
|
|
|
@ -23,7 +23,7 @@ import {
|
||||||
AccountMethods
|
AccountMethods
|
||||||
} from './account-interface'
|
} from './account-interface'
|
||||||
import { sendDeleteAccount } from '../../lib/activitypub/send-request'
|
import { sendDeleteAccount } from '../../lib/activitypub/send-request'
|
||||||
import { CONSTRAINTS_FIELDS } from '../../initializers/constants'
|
import { CONFIG, CONSTRAINTS_FIELDS } from '../../initializers/constants'
|
||||||
|
|
||||||
let Account: Sequelize.Model<AccountInstance, AccountAttributes>
|
let Account: Sequelize.Model<AccountInstance, AccountAttributes>
|
||||||
let loadAccountByPodAndUUID: AccountMethods.LoadAccountByPodAndUUID
|
let loadAccountByPodAndUUID: AccountMethods.LoadAccountByPodAndUUID
|
||||||
|
@ -34,10 +34,6 @@ let loadByUrl: AccountMethods.LoadByUrl
|
||||||
let loadLocalByName: AccountMethods.LoadLocalByName
|
let loadLocalByName: AccountMethods.LoadLocalByName
|
||||||
let loadByNameAndHost: AccountMethods.LoadByNameAndHost
|
let loadByNameAndHost: AccountMethods.LoadByNameAndHost
|
||||||
let listOwned: AccountMethods.ListOwned
|
let listOwned: AccountMethods.ListOwned
|
||||||
let listAcceptedFollowerUrlsForApi: AccountMethods.ListAcceptedFollowerUrlsForApi
|
|
||||||
let listAcceptedFollowingUrlsForApi: AccountMethods.ListAcceptedFollowingUrlsForApi
|
|
||||||
let listFollowingForApi: AccountMethods.ListFollowingForApi
|
|
||||||
let listFollowersForApi: AccountMethods.ListFollowersForApi
|
|
||||||
let isOwned: AccountMethods.IsOwned
|
let isOwned: AccountMethods.IsOwned
|
||||||
let toActivityPubObject: AccountMethods.ToActivityPubObject
|
let toActivityPubObject: AccountMethods.ToActivityPubObject
|
||||||
let toFormattedJSON: AccountMethods.ToFormattedJSON
|
let toFormattedJSON: AccountMethods.ToFormattedJSON
|
||||||
|
@ -185,7 +181,7 @@ export default function defineAccount (sequelize: Sequelize.Sequelize, DataTypes
|
||||||
unique: true
|
unique: true
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
fields: [ 'name', 'podId' ],
|
fields: [ 'name', 'podId', 'applicationId' ],
|
||||||
unique: true
|
unique: true
|
||||||
}
|
}
|
||||||
],
|
],
|
||||||
|
@ -202,11 +198,7 @@ export default function defineAccount (sequelize: Sequelize.Sequelize, DataTypes
|
||||||
loadByUrl,
|
loadByUrl,
|
||||||
loadLocalByName,
|
loadLocalByName,
|
||||||
loadByNameAndHost,
|
loadByNameAndHost,
|
||||||
listOwned,
|
listOwned
|
||||||
listAcceptedFollowerUrlsForApi,
|
|
||||||
listAcceptedFollowingUrlsForApi,
|
|
||||||
listFollowingForApi,
|
|
||||||
listFollowersForApi
|
|
||||||
]
|
]
|
||||||
const instanceMethods = [
|
const instanceMethods = [
|
||||||
isOwned,
|
isOwned,
|
||||||
|
@ -286,9 +278,11 @@ function afterDestroy (account: AccountInstance) {
|
||||||
}
|
}
|
||||||
|
|
||||||
toFormattedJSON = function (this: AccountInstance) {
|
toFormattedJSON = function (this: AccountInstance) {
|
||||||
|
let host = this.Pod ? this.Pod.host : CONFIG.WEBSERVER.HOST
|
||||||
|
|
||||||
const json = {
|
const json = {
|
||||||
id: this.id,
|
id: this.id,
|
||||||
host: this.Pod.host,
|
host,
|
||||||
name: this.name
|
name: this.name
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -346,7 +340,7 @@ getFollowerSharedInboxUrls = function (this: AccountInstance) {
|
||||||
}
|
}
|
||||||
|
|
||||||
getFollowingUrl = function (this: AccountInstance) {
|
getFollowingUrl = function (this: AccountInstance) {
|
||||||
return this.url + '/followers'
|
return this.url + '/following'
|
||||||
}
|
}
|
||||||
|
|
||||||
getFollowersUrl = function (this: AccountInstance) {
|
getFollowersUrl = function (this: AccountInstance) {
|
||||||
|
@ -369,76 +363,6 @@ listOwned = function () {
|
||||||
return Account.findAll(query)
|
return Account.findAll(query)
|
||||||
}
|
}
|
||||||
|
|
||||||
listAcceptedFollowerUrlsForApi = function (id: number, start: number, count?: number) {
|
|
||||||
return createListAcceptedFollowForApiQuery('followers', id, start, count)
|
|
||||||
}
|
|
||||||
|
|
||||||
listAcceptedFollowingUrlsForApi = function (id: number, start: number, count?: number) {
|
|
||||||
return createListAcceptedFollowForApiQuery('following', id, start, count)
|
|
||||||
}
|
|
||||||
|
|
||||||
listFollowingForApi = function (id: number, start: number, count: number, sort: string) {
|
|
||||||
const query = {
|
|
||||||
distinct: true,
|
|
||||||
offset: start,
|
|
||||||
limit: count,
|
|
||||||
order: [ getSort(sort) ],
|
|
||||||
include: [
|
|
||||||
{
|
|
||||||
model: Account['sequelize'].models.AccountFollow,
|
|
||||||
required: true,
|
|
||||||
as: 'following',
|
|
||||||
include: [
|
|
||||||
{
|
|
||||||
model: Account['sequelize'].models.Account,
|
|
||||||
as: 'accountFollowing',
|
|
||||||
required: true,
|
|
||||||
include: [ Account['sequelize'].models.Pod ]
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
|
|
||||||
return Account.findAndCountAll(query).then(({ rows, count }) => {
|
|
||||||
return {
|
|
||||||
data: rows,
|
|
||||||
total: count
|
|
||||||
}
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
listFollowersForApi = function (id: number, start: number, count: number, sort: string) {
|
|
||||||
const query = {
|
|
||||||
distinct: true,
|
|
||||||
offset: start,
|
|
||||||
limit: count,
|
|
||||||
order: [ getSort(sort) ],
|
|
||||||
include: [
|
|
||||||
{
|
|
||||||
model: Account['sequelize'].models.AccountFollow,
|
|
||||||
required: true,
|
|
||||||
as: 'followers',
|
|
||||||
include: [
|
|
||||||
{
|
|
||||||
model: Account['sequelize'].models.Account,
|
|
||||||
as: 'accountFollowers',
|
|
||||||
required: true,
|
|
||||||
include: [ Account['sequelize'].models.Pod ]
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
|
|
||||||
return Account.findAndCountAll(query).then(({ rows, count }) => {
|
|
||||||
return {
|
|
||||||
data: rows,
|
|
||||||
total: count
|
|
||||||
}
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
loadApplication = function () {
|
loadApplication = function () {
|
||||||
return Account.findOne({
|
return Account.findOne({
|
||||||
include: [
|
include: [
|
||||||
|
@ -527,45 +451,3 @@ loadAccountByPodAndUUID = function (uuid: string, podId: number, transaction: Se
|
||||||
|
|
||||||
return Account.find(query)
|
return Account.find(query)
|
||||||
}
|
}
|
||||||
|
|
||||||
// ------------------------------ UTILS ------------------------------
|
|
||||||
|
|
||||||
async function createListAcceptedFollowForApiQuery (type: 'followers' | 'following', id: number, start: number, count?: number) {
|
|
||||||
let firstJoin: string
|
|
||||||
let secondJoin: string
|
|
||||||
|
|
||||||
if (type === 'followers') {
|
|
||||||
firstJoin = 'targetAccountId'
|
|
||||||
secondJoin = 'accountId'
|
|
||||||
} else {
|
|
||||||
firstJoin = 'accountId'
|
|
||||||
secondJoin = 'targetAccountId'
|
|
||||||
}
|
|
||||||
|
|
||||||
const selections = [ '"Followers"."url" AS "url"', 'COUNT(*) AS "total"' ]
|
|
||||||
const tasks: Promise<any>[] = []
|
|
||||||
|
|
||||||
for (const selection of selections) {
|
|
||||||
let query = 'SELECT ' + selection + ' FROM "Account" ' +
|
|
||||||
'INNER JOIN "AccountFollow" ON "AccountFollow"."' + firstJoin + '" = "Account"."id" ' +
|
|
||||||
'INNER JOIN "Account" AS "Follows" ON "Followers"."id" = "Follows"."' + secondJoin + '" ' +
|
|
||||||
'WHERE "Account"."id" = $id AND "AccountFollow"."state" = \'accepted\' ' +
|
|
||||||
'LIMIT ' + start
|
|
||||||
|
|
||||||
if (count !== undefined) query += ', ' + count
|
|
||||||
|
|
||||||
const options = {
|
|
||||||
bind: { id },
|
|
||||||
type: Sequelize.QueryTypes.SELECT
|
|
||||||
}
|
|
||||||
tasks.push(Account['sequelize'].query(query, options))
|
|
||||||
}
|
|
||||||
|
|
||||||
const [ followers, [ { total } ]] = await Promise.all(tasks)
|
|
||||||
const urls: string[] = followers.map(f => f.url)
|
|
||||||
|
|
||||||
return {
|
|
||||||
data: urls,
|
|
||||||
total: parseInt(total, 10)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
|
@ -1,9 +1,9 @@
|
||||||
export enum UserRight {
|
export enum UserRight {
|
||||||
ALL,
|
ALL,
|
||||||
MANAGE_USERS,
|
MANAGE_USERS,
|
||||||
MANAGE_PEERTUBE_FOLLOW,
|
MANAGE_APPLICATION_FOLLOW,
|
||||||
MANAGE_VIDEO_ABUSES,
|
MANAGE_VIDEO_ABUSES,
|
||||||
MANAGE_VIDEO_BLACKLIST,
|
MANAGE_VIDEO_BLACKLIST,
|
||||||
REMOVE_ANY_VIDEO,
|
REMOVE_ANY_VIDEO,
|
||||||
REMOVE_ANY_VIDEO_CHANNEL,
|
REMOVE_ANY_VIDEO_CHANNEL
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue