Add comments app for accessing Twitch comments

master
Nikola Forró 6 years ago
parent f56df57490
commit 2c57699107

@ -10,6 +10,16 @@ COPY apps/quotes .
RUN $(npm bin)/ng build --prod --build-optimizer --output-hashing=none RUN $(npm bin)/ng build --prod --build-optimizer --output-hashing=none
WORKDIR /build-comments
COPY apps/comments/package.json apps/comments/package-lock.json ./
RUN npm install && mkdir /comments && cp -r node_modules/ /comments
WORKDIR /comments
COPY apps/comments .
RUN $(npm bin)/ng build --prod --build-optimizer --output-hashing=none
WORKDIR /build-schedule WORKDIR /build-schedule
COPY apps/schedule/package.json apps/schedule/package-lock.json ./ COPY apps/schedule/package.json apps/schedule/package-lock.json ./
@ -25,6 +35,7 @@ FROM nginx:alpine
COPY nginx/nginx.conf /etc/nginx/nginx.conf COPY nginx/nginx.conf /etc/nginx/nginx.conf
COPY --from=builder /quotes/dist /quotes/quotes/assets COPY --from=builder /quotes/dist /quotes/quotes/assets
COPY --from=builder /comments/dist /comments/comments/assets
COPY --from=builder /schedule/dist /schedule/schedule/assets COPY --from=builder /schedule/dist /schedule/schedule/assets
RUN addgroup -g 9999 lilia RUN addgroup -g 9999 lilia

@ -0,0 +1,61 @@
{
"$schema": "./node_modules/@angular/cli/lib/config/schema.json",
"project": {
"name": "comments"
},
"apps": [
{
"root": "src",
"outDir": "dist",
"assets": [
"assets",
"favicon.ico"
],
"index": "index.html",
"main": "main.ts",
"polyfills": "polyfills.ts",
"test": "test.ts",
"tsconfig": "tsconfig.app.json",
"testTsconfig": "tsconfig.spec.json",
"prefix": "app",
"styles": [
"styles.css",
"theme.scss"
],
"scripts": [],
"environmentSource": "environments/environment.ts",
"environments": {
"dev": "environments/environment.ts",
"prod": "environments/environment.prod.ts"
}
}
],
"e2e": {
"protractor": {
"config": "./protractor.conf.js"
}
},
"lint": [
{
"project": "src/tsconfig.app.json",
"exclude": "**/node_modules/**"
},
{
"project": "src/tsconfig.spec.json",
"exclude": "**/node_modules/**"
},
{
"project": "e2e/tsconfig.e2e.json",
"exclude": "**/node_modules/**"
}
],
"test": {
"karma": {
"config": "./karma.conf.js"
}
},
"defaults": {
"styleExt": "css",
"component": {}
}
}

@ -0,0 +1,13 @@
# Editor configuration, see http://editorconfig.org
root = true
[*]
charset = utf-8
indent_style = space
indent_size = 2
insert_final_newline = true
trim_trailing_whitespace = true
[*.md]
max_line_length = off
trim_trailing_whitespace = false

@ -0,0 +1,44 @@
# See http://help.github.com/ignore-files/ for more about ignoring files.
# compiled output
/dist
/dist-server
/tmp
/out-tsc
# dependencies
/node_modules
# IDEs and editors
/.idea
.project
.classpath
.c9/
*.launch
.settings/
*.sublime-workspace
# IDE - VSCode
.vscode/*
!.vscode/settings.json
!.vscode/tasks.json
!.vscode/launch.json
!.vscode/extensions.json
# misc
/.sass-cache
/connect.lock
/coverage
/libpeerconnection.log
npm-debug.log
yarn-error.log
testem.log
/typings
# e2e
/e2e/*.js
/e2e/*.map
# System Files
.DS_Store
Thumbs.db

@ -0,0 +1,27 @@
# Logs
This project was generated with [Angular CLI](https://github.com/angular/angular-cli) version 1.7.3.
## Development server
Run `ng serve` for a dev server. Navigate to `http://localhost:4200/`. The app will automatically reload if you change any of the source files.
## Code scaffolding
Run `ng generate component component-name` to generate a new component. You can also use `ng generate directive|pipe|service|class|guard|interface|enum|module`.
## Build
Run `ng build` to build the project. The build artifacts will be stored in the `dist/` directory. Use the `-prod` flag for a production build.
## Running unit tests
Run `ng test` to execute the unit tests via [Karma](https://karma-runner.github.io).
## Running end-to-end tests
Run `ng e2e` to execute the end-to-end tests via [Protractor](http://www.protractortest.org/).
## Further help
To get more help on the Angular CLI use `ng help` or go check out the [Angular CLI README](https://github.com/angular/angular-cli/blob/master/README.md).

@ -0,0 +1,14 @@
import { AppPage } from './app.po';
describe('logs App', () => {
let page: AppPage;
beforeEach(() => {
page = new AppPage();
});
it('should display welcome message', () => {
page.navigateTo();
expect(page.getParagraphText()).toEqual('Welcome to app!');
});
});

@ -0,0 +1,11 @@
import { browser, by, element } from 'protractor';
export class AppPage {
navigateTo() {
return browser.get('/');
}
getParagraphText() {
return element(by.css('app-root h1')).getText();
}
}

@ -0,0 +1,14 @@
{
"extends": "../tsconfig.json",
"compilerOptions": {
"outDir": "../out-tsc/e2e",
"baseUrl": "./",
"module": "commonjs",
"target": "es5",
"types": [
"jasmine",
"jasminewd2",
"node"
]
}
}

@ -0,0 +1,33 @@
// Karma configuration file, see link for more information
// https://karma-runner.github.io/1.0/config/configuration-file.html
module.exports = function (config) {
config.set({
basePath: '',
frameworks: ['jasmine', '@angular/cli'],
plugins: [
require('karma-jasmine'),
require('karma-chrome-launcher'),
require('karma-jasmine-html-reporter'),
require('karma-coverage-istanbul-reporter'),
require('@angular/cli/plugins/karma')
],
client:{
clearContext: false // leave Jasmine Spec Runner output visible in browser
},
coverageIstanbulReporter: {
reports: [ 'html', 'lcovonly' ],
fixWebpackSourcePaths: true
},
angularCli: {
environment: 'dev'
},
reporters: ['progress', 'kjhtml'],
port: 9876,
colors: true,
logLevel: config.LOG_INFO,
autoWatch: true,
browsers: ['Chrome'],
singleRun: false
});
};

File diff suppressed because it is too large Load Diff

@ -0,0 +1,53 @@
{
"name": "logs",
"version": "0.0.0",
"license": "MIT",
"scripts": {
"ng": "ng",
"start": "ng serve",
"build": "ng build --prod",
"test": "ng test",
"lint": "ng lint",
"e2e": "ng e2e"
},
"private": true,
"dependencies": {
"@angular/animations": "^5.2.0",
"@angular/cdk": "^5.2.5",
"@angular/common": "^5.2.0",
"@angular/compiler": "^5.2.0",
"@angular/core": "^5.2.0",
"@angular/flex-layout": "^5.0.0-beta.14",
"@angular/forms": "^5.2.0",
"@angular/http": "^5.2.0",
"@angular/material": "^5.2.5",
"@angular/platform-browser": "^5.2.0",
"@angular/platform-browser-dynamic": "^5.2.0",
"@angular/router": "^5.2.0",
"core-js": "^2.4.1",
"hammerjs": "^2.0.8",
"node-sass": "^4.9.0",
"rxjs": "^5.5.6",
"zone.js": "^0.8.19"
},
"devDependencies": {
"@angular/cli": "~1.7.3",
"@angular/compiler-cli": "^5.2.0",
"@angular/language-service": "^5.2.0",
"@types/jasmine": "~2.8.3",
"@types/jasminewd2": "~2.0.2",
"@types/node": "~6.0.60",
"codelyzer": "^4.0.1",
"jasmine-core": "~2.8.0",
"jasmine-spec-reporter": "~4.2.1",
"karma": "~2.0.0",
"karma-chrome-launcher": "~2.2.0",
"karma-coverage-istanbul-reporter": "^1.2.1",
"karma-jasmine": "~1.1.0",
"karma-jasmine-html-reporter": "^0.2.2",
"protractor": "~5.1.2",
"ts-node": "~4.1.0",
"tslint": "~5.9.1",
"typescript": "~2.5.3"
}
}

@ -0,0 +1,28 @@
// Protractor configuration file, see link for more information
// https://github.com/angular/protractor/blob/master/lib/config.ts
const { SpecReporter } = require('jasmine-spec-reporter');
exports.config = {
allScriptsTimeout: 11000,
specs: [
'./e2e/**/*.e2e-spec.ts'
],
capabilities: {
'browserName': 'chrome'
},
directConnect: true,
baseUrl: 'http://localhost:4200/',
framework: 'jasmine',
jasmineNodeOpts: {
showColors: true,
defaultTimeoutInterval: 30000,
print: function() {}
},
onPrepare() {
require('ts-node').register({
project: 'e2e/tsconfig.e2e.json'
});
jasmine.getEnv().addReporter(new SpecReporter({ spec: { displayStacktrace: true } }));
}
};

@ -0,0 +1,3 @@
>>> body {
margin: 0;
}

@ -0,0 +1 @@
<router-outlet></router-outlet>

@ -0,0 +1,27 @@
import { TestBed, async } from '@angular/core/testing';
import { AppComponent } from './app.component';
describe('AppComponent', () => {
beforeEach(async(() => {
TestBed.configureTestingModule({
declarations: [
AppComponent
],
}).compileComponents();
}));
it('should create the app', async(() => {
const fixture = TestBed.createComponent(AppComponent);
const app = fixture.debugElement.componentInstance;
expect(app).toBeTruthy();
}));
it(`should have as title 'app'`, async(() => {
const fixture = TestBed.createComponent(AppComponent);
const app = fixture.debugElement.componentInstance;
expect(app.title).toEqual('app');
}));
it('should render title in a h1 tag', async(() => {
const fixture = TestBed.createComponent(AppComponent);
fixture.detectChanges();
const compiled = fixture.debugElement.nativeElement;
expect(compiled.querySelector('h1').textContent).toContain('Welcome to app!');
}));
});

@ -0,0 +1,11 @@
import { Component } from '@angular/core';
@Component({
selector: 'app-root',
templateUrl: './app.component.html',
styleUrls: ['./app.component.css']
})
export class AppComponent {
title = 'app';
}

@ -0,0 +1,70 @@
import { BrowserModule } from '@angular/platform-browser';
import { BrowserAnimationsModule } from "@angular/platform-browser/animations";
import { NgModule } from '@angular/core';
import { HttpClientModule } from '@angular/common/http';
import {
Routes,
RouterModule
} from '@angular/router';
import {
MatInputModule,
MatPaginatorModule,
MatProgressSpinnerModule,
MatSortModule,
MatToolbarModule,
MatTableModule
} from '@angular/material';
import { MatButtonModule } from '@angular/material/button';
import { FlexLayoutModule } from "@angular/flex-layout";
import { AppComponent } from './app.component';
import { VideosComponent } from './videos/videos.component';
import { CommentsComponent } from './comments/comments.component';
import { SplitBadgesPipe } from './pipes/splitbadges.pipe';
import { SplitMessagePipe } from './pipes/splitmessage.pipe';
import { ToHMSPipe } from './pipes/tohms.pipe';
import { CommentsService } from './services/comments.service';
import { ImagesService } from './services/images.service';
const routes: Routes = [
{ path: '', component: VideosComponent },
{ path: 'videos/:id', component: CommentsComponent },
{ path: '**', redirectTo: '/' }
];
@NgModule({
declarations: [
AppComponent,
VideosComponent,
CommentsComponent,
SplitBadgesPipe,
SplitMessagePipe,
ToHMSPipe
],
imports: [
BrowserModule,
BrowserAnimationsModule,
HttpClientModule,
FlexLayoutModule,
MatButtonModule,
MatInputModule,
MatPaginatorModule,
MatProgressSpinnerModule,
MatSortModule,
MatToolbarModule,
MatTableModule,
RouterModule.forRoot(routes)
],
providers: [
CommentsService,
ImagesService
],
bootstrap: [ AppComponent ]
})
export class AppModule { }

@ -0,0 +1,26 @@
.comments {
text-align: center;
}
.comments-table {
text-align: left;
}
.mat-column-commenter_display_name {
font-weight: 500;
}
.spacer {
flex: 1 1 auto;
}
.spinner-container {
position: fixed;
left: 50%;
top: 15%;
margin-left: -50px;
}
.spinner-container mat-spinner {
margin: 6em auto 0 auto;
}

@ -0,0 +1,92 @@
<div class="comments">
<mat-toolbar>
<mat-input-container class="search">
<input matInput placeholder="Search comments" #input>
</mat-input-container>
<span class="spacer"></span>
</mat-toolbar>
<div class="spinner-container" *ngIf="dataSource.loading$ | async">
<mat-spinner></mat-spinner>
</div>
<mat-table class="comments-table mat-elevation-z8" [dataSource]="dataSource"
matSort matSortActive="offset" matSortDirection="asc" matSortDisableClear>
<ng-container matColumnDef="offset">
<mat-header-cell fxFlex="15%" *matHeaderCellDef mat-sort-header>Offset</mat-header-cell>
<mat-cell fxFlex="15%" *matCellDef="let comment">
<a mat-button href="https://www.twitch.tv/videos/{{videoID}}?comment={{comment.id}}&t={{comment.offset | tohms : 'units'}}" target="_blank">
{{comment.offset | tohms}}
</a>
</mat-cell>
</ng-container>
<ng-container matColumnDef="commenter_display_name">
<mat-header-cell fxFlex="25%" *matHeaderCellDef mat-sort-header>Commenter</mat-header-cell>
<mat-cell fxFlex="25%" *matCellDef="let comment">
<span *ngIf="comment.message_user_badges">
<ng-template ngFor let-token [ngForOf]="badges$ | async | splitbadges : comment.message_user_badges">
<img src="{{token.url}}" alt="{{token.title}}" *ngIf="token.hasOwnProperty('url')">
</ng-template>
</span>
<span [ngStyle]="{color: comment.message_user_color}">
{{comment.commenter_display_name}}
</span>
</mat-cell>
</ng-container>
<ng-container matColumnDef="message_body">
<mat-header-cell fxFlex="60%" *matHeaderCellDef mat-sort-header>Message</mat-header-cell>
<mat-cell fxFlex="60%" *matCellDef="let comment">
<ng-template ngFor let-token [ngForOf]="emotes$ | async | splitmessage : comment.message_body">
<img src="{{token.url}}" alt="{{token.title}}" *ngIf="token.hasOwnProperty('url')">
<span *ngIf="!token.hasOwnProperty('url')">{{token}}</span>
</ng-template>
</mat-cell>
</ng-container>
<mat-header-row *matHeaderRowDef="displayedColumns"></mat-header-row>
<mat-row *matRowDef="let row; columns: displayedColumns"></mat-row>
</mat-table>
<mat-paginator [length]="dataSource?.count$ | async" [pageSize]="20"
[pageSizeOptions]="[10, 20, 50, 100, 200]"></mat-paginator>
</div>

@ -0,0 +1,112 @@
import {
AfterViewInit,
Component,
ElementRef,
OnDestroy,
OnInit,
ViewChild
} from '@angular/core';
import { ActivatedRoute } from '@angular/router';
import {
MatPaginator,
MatSort,
MatTableDataSource
} from '@angular/material';
import { BehaviorSubject } from 'rxjs/BehaviorSubject';
import {
debounceTime,
delay,
distinctUntilChanged,
startWith,
tap
} from 'rxjs/operators';
import { merge } from 'rxjs/observable/merge';
import { fromEvent } from 'rxjs/observable/fromEvent';
import { CommentsService } from '../services/comments.service';
import { ImagesService } from '../services/images.service';
import { CommentsDataSource } from '../services/comments.datasource';
@Component({
selector: 'comments',
templateUrl: './comments.component.html',
styleUrls: [ './comments.component.css' ]
})
export class CommentsComponent implements OnInit, OnDestroy, AfterViewInit {
private badgesSubject = new BehaviorSubject<any[]>([]);
private emotesSubject = new BehaviorSubject<any[]>([]);
dataSource: CommentsDataSource;
videoID: string;
displayedColumns = [
'offset',
'commenter_display_name',
'message_body'
];
@ViewChild(MatPaginator) paginator: MatPaginator;
@ViewChild(MatSort) sort: MatSort;
@ViewChild('input') input: ElementRef;
public badges$ = this.badgesSubject.asObservable();
public emotes$ = this.emotesSubject.asObservable();
constructor(private route: ActivatedRoute,
private commentsService: CommentsService,
private imagesService: ImagesService) { }
ngOnInit() {
this.dataSource = new CommentsDataSource(this.commentsService);
this.videoID = this.route.snapshot.paramMap.get('id');
this.dataSource.loadComments(this.videoID, '', 'offset', 'asc', 0, 20);
this.imagesService.getBadges().subscribe(
(data: any[]) => this.badgesSubject.next(data)
);
this.imagesService.getEmotes().subscribe(
(data: any[]) => this.emotesSubject.next(data)
);
}
ngOnDestroy() {
this.badgesSubject.complete();
this.emotesSubject.complete();
}
ngAfterViewInit() {
this.sort.sortChange.subscribe(() => this.paginator.pageIndex = 0);
fromEvent(this.input.nativeElement, 'keyup')
.pipe(
debounceTime(150),
distinctUntilChanged(),
tap(() => {
this.paginator.pageIndex = 0;
this.loadCommentsPage();
})
)
.subscribe();
merge(this.sort.sortChange, this.paginator.page)
.pipe(
tap(() => this.loadCommentsPage())
)
.subscribe();
}
loadCommentsPage() {
this.dataSource.loadComments(
this.videoID,
this.input.nativeElement.value,
this.sort.active,
this.sort.direction,
this.paginator.pageIndex,
this.paginator.pageSize);
}
}

@ -0,0 +1,15 @@
export interface Comment {
id: string;
video_id: number;
offset: number;
commenter_id: string;
commenter_name: string;
commenter_display_name: string;
commenter_logo: string;
source: string;
message_body: string;
message_user_color: string;
message_user_badges: string;
created_at: Date;
updated_at: Date;
}

@ -0,0 +1,15 @@
export interface Video {
id: number;
broadcast_type: string;
title: string;
description: string;
game: string;
length: number;
thumbnail_small: string;
thumbnail_medium: string;
thumbnail_large: string;
created_at: Date;
updated_at: Date;
recorded_at: Date;
published_at: Date;
}

@ -0,0 +1,23 @@
import {
Pipe,
PipeTransform
} from '@angular/core';
@Pipe({
name: 'splitbadges'
})
export class SplitBadgesPipe implements PipeTransform {
transform(badges: any[], badgeList: string): any[] {
if (badges.length == 0) {
return [];
}
return badgeList.split(',').map((id: string) => {
let b = badges.filter((badge: any) => badge.id == id)
return b.length > 0 ? b[0] : id;
});
}
}

@ -0,0 +1,31 @@
import {
Pipe,
PipeTransform
} from '@angular/core';
@Pipe({
name: 'splitmessage'
})
export class SplitMessagePipe implements PipeTransform {
transform(emotes: any[], message: string): any[] {
if (emotes.length == 0) {
return [];
}
let exps = emotes.map(
(emote: any) => emote.title.replace(/[-\/\\^$*+?.()|[\]{}]/g, '\\$&')
);
let regexp = RegExp('(' + exps.join('|') + ')');
let tokens = message.split(regexp);
return tokens.map((token: any) => {
let e = emotes.filter((emote: any) => emote.title == token);
return e.length > 0 ? e[0] : token;
});
}
}

@ -0,0 +1,25 @@
import {
Pipe,
PipeTransform
} from '@angular/core';
@Pipe({
name: 'tohms'
})
export class ToHMSPipe implements PipeTransform {
transform(offset: number): string {
let secs = offset >> 0;
let seconds = secs % 60;
let mins = (secs - seconds) / 60 >> 0;
let minutes = mins % 60;
let hours = (mins - minutes) / 60 >> 0;
let s = seconds.toString().padStart(2, '0');
let m = minutes.toString().padStart(2, '0');
let h = hours.toString().padStart(2, '0');
return `${h}h${m}m${s}s`;
}
}

@ -0,0 +1,61 @@
import {
CollectionViewer,
DataSource
} from '@angular/cdk/collections';
import { Observable } from 'rxjs/Observable';
import { BehaviorSubject } from 'rxjs/BehaviorSubject';
import { of } from 'rxjs/observable/of';
import {
catchError,
finalize
} from 'rxjs/operators';
import { CommentsService } from './comments.service';
import { Comment } from '../models/comment';
export class CommentsDataSource implements DataSource<Comment> {
private commentsSubject = new BehaviorSubject<Comment[]>([]);
private countSubject = new BehaviorSubject<number>(0);
private loadingSubject = new BehaviorSubject<boolean>(false);
public count$ = this.countSubject.asObservable();
public loading$ = this.loadingSubject.asObservable();
constructor(private commentsService: CommentsService) { }
loadComments(videoID: string,
filter: string,
sortColumn: string,
sortDirection: string,
pageIndex: number,
pageSize: number) {
this.loadingSubject.next(true);
this.commentsService.findComments(videoID, filter, sortColumn, sortDirection,
pageIndex, pageSize)
.pipe(
catchError(() => of([])),
finalize(() => this.loadingSubject.next(false))
)
.subscribe((data: any) => {
this.commentsSubject.next(data.comments);
this.countSubject.next(data.totalCount);
});
}
connect(collectionViewer: CollectionViewer): Observable<Comment[]> {
console.log('Connecting data source');
return this.commentsSubject.asObservable();
}
disconnect(collectionViewer: CollectionViewer): void {
this.commentsSubject.complete();
this.countSubject.complete();
this.loadingSubject.complete();
}
}

@ -0,0 +1,59 @@
import { Injectable } from '@angular/core';
import {
HttpClient,
HttpParams
} from '@angular/common/http';
import { Observable } from 'rxjs/Observable';
import { map } from 'rxjs/operators';
import { Video } from '../models/video';
import { Comment } from '../models/comment';
@Injectable()
export class CommentsService {
constructor(private http: HttpClient) { }
findVideos(
filter = '', sortBy = 'recorded_at', sortOrder = 'desc',
pageNumber = 0, pageSize = 20): Observable<any> {
return this.http.get('/comments/api/videos', {
observe: 'response',
params: new HttpParams()
.set('filter', filter)
.set('sort_by', sortBy)
.set('sort_order', sortOrder)
.set('page_number', pageNumber.toString())
.set('page_size', pageSize.toString())
}).pipe(
map((res: any) => ({
videos: <Video[]>res.body,
totalCount: parseInt(res.headers.get('X-Total-Count'))
}))
);
}
findComments(videoID,
filter = '', sortBy = 'offset', sortOrder = 'asc',
pageNumber = 0, pageSize = 20): Observable<any> {
return this.http.get('/comments/api/videos/' + videoID + '/comments', {
observe: 'response',
params: new HttpParams()
.set('filter', filter)
.set('sort_by', sortBy)
.set('sort_order', sortOrder)
.set('page_number', pageNumber.toString())
.set('page_size', pageSize.toString())
}).pipe(
map((res: any) => ({
comments: <Comment[]>res.body,
totalCount: parseInt(res.headers.get('X-Total-Count'))
}))
);
}
}

@ -0,0 +1,56 @@
import { Injectable } from '@angular/core';
import { HttpClient } from '@angular/common/http';
import { Observable } from 'rxjs/Observable';
import { forkJoin } from "rxjs/observable/forkJoin";
import { map } from 'rxjs/operators';
const CHANNEL_ID = 92737529;
@Injectable()
export class ImagesService {
constructor(private http: HttpClient) { }
getBadges(): Observable<any> {
return forkJoin([
this.http.get('https://badges.twitch.tv/v1/badges/global/display'),
this.http.get('https://badges.twitch.tv/v1/badges/channels/' + CHANNEL_ID + '/display')
]).pipe(
map((res: any[]) => {
let sets = Object.assign({}, res[0].badge_sets, res[1].badge_sets);
let badges = [];
for (let set of Object.keys(sets)) {
let versions = sets[set].versions;
for (let ver of Object.keys(versions)) {
badges.push({
id: set + ':' + ver,
title: versions[ver].title,
url: versions[ver].image_url_1x
});
}
}
return badges;
})
);
}
getEmotes(): Observable<any> {
return this.http.get('/comments/api/emotes').pipe(
map((res: any[]) => {
return res.map((emote: any) => ({
id: emote.id,
title: emote.code,
url: 'https://static-cdn.jtvnw.net/emoticons/v1/' + emote.id + '/1.0'
}));
})
);
}
}

@ -0,0 +1,60 @@
import {
CollectionViewer,
DataSource
} from '@angular/cdk/collections';
import { Observable } from 'rxjs/Observable';
import { BehaviorSubject } from 'rxjs/BehaviorSubject';
import { of } from 'rxjs/observable/of';
import {
catchError,
finalize
} from 'rxjs/operators';
import { CommentsService } from './comments.service';
import { Video } from '../models/video';
export class VideosDataSource implements DataSource<Video> {
private videosSubject = new BehaviorSubject<Video[]>([]);
private countSubject = new BehaviorSubject<number>(0);
private loadingSubject = new BehaviorSubject<boolean>(false);
public count$ = this.countSubject.asObservable();
public loading$ = this.loadingSubject.asObservable();
constructor(private commentsService: CommentsService) { }
loadVideos(filter: string,
sortColumn: string,
sortDirection: string,
pageIndex: number,
pageSize: number) {
this.loadingSubject.next(true);
this.commentsService.findVideos(filter, sortColumn, sortDirection,
pageIndex, pageSize)
.pipe(
catchError(() => of([])),
finalize(() => this.loadingSubject.next(false))
)
.subscribe((data: any) => {
this.videosSubject.next(data.videos);
this.countSubject.next(data.totalCount);
});
}
connect(collectionViewer: CollectionViewer): Observable<Video[]> {
console.log('Connecting data source');
return this.videosSubject.asObservable();
}
disconnect(collectionViewer: CollectionViewer): void {
this.videosSubject.complete();
this.countSubject.complete();
this.loadingSubject.complete();
}
}

@ -0,0 +1,22 @@
.videos {
text-align: center;
}
.videos-table {
text-align: left;
}
.spacer {
flex: 1 1 auto;
}
.spinner-container {
position: fixed;
left: 50%;
top: 15%;
margin-left: -50px;
}
.spinner-container mat-spinner {
margin: 6em auto 0 auto;
}

@ -0,0 +1,75 @@
<div class="videos">
<mat-toolbar>
<mat-input-container class="search">
<input matInput placeholder="Search videos" #input>
</mat-input-container>
<span class="spacer"></span>
</mat-toolbar>
<div class="spinner-container" *ngIf="dataSource.loading$ | async">
<mat-spinner></mat-spinner>
</div>
<mat-table class="videos-table mat-elevation-z8" [dataSource]="dataSource"
matSort matSortActive="recorded_at" matSortDirection="desc" matSortDisableClear>
<ng-container matColumnDef="recorded_at">
<mat-header-cell fxFlex="10%" *matHeaderCellDef mat-sort-header>Recorded</mat-header-cell>
<mat-cell fxFlex="10%" *matCellDef="let video">{{video.recorded_at | date : 'yyyy-MM-dd'}}</mat-cell>
</ng-container>
<ng-container matColumnDef="title">
<mat-header-cell fxFlex="50%" *matHeaderCellDef mat-sort-header>Title</mat-header-cell>
<mat-cell fxFlex="50%" *matCellDef="let video">
<img src="{{video.thumbnail_small}}" alt="{{video.title}}">
<a mat-button [routerLink]="['/videos', video.id]">
{{video.title}}
</a>
</mat-cell>
</ng-container>
<ng-container matColumnDef="game">
<mat-header-cell fxFlex="28%" *matHeaderCellDef mat-sort-header>Game</mat-header-cell>
<mat-cell fxFlex="28%" *matCellDef="let video">{{video.game}}</mat-cell>
</ng-container>
<ng-container matColumnDef="length">
<mat-header-cell fxFlex="12%" *matHeaderCellDef mat-sort-header>Length</mat-header-cell>
<mat-cell fxFlex="12%" *matCellDef="let video">{{video.length | tohms}}</mat-cell>
</ng-container>
<mat-header-row *matHeaderRowDef="displayedColumns"></mat-header-row>
<mat-row *matRowDef="let row; columns: displayedColumns"></mat-row>
</mat-table>
<mat-paginator [length]="dataSource?.count$ | async" [pageSize]="20"
[pageSizeOptions]="[10, 20, 50, 100, 200]"></mat-paginator>
</div>

@ -0,0 +1,88 @@
import {
AfterViewInit,
Component,
ElementRef,
OnInit,
ViewChild
} from '@angular/core';
import { ActivatedRoute } from '@angular/router';
import {
MatPaginator,
MatSort,
MatTableDataSource
} from '@angular/material';
import {
debounceTime,
distinctUntilChanged,
startWith,
tap,
delay
} from 'rxjs/operators';
import { merge } from 'rxjs/observable/merge';
import { fromEvent } from 'rxjs/observable/fromEvent';
import { CommentsService } from '../services/comments.service';
import { VideosDataSource } from '../services/videos.datasource';
@Component({
selector: 'videos',
templateUrl: './videos.component.html',
styleUrls: [ './videos.component.css' ]
})
export class VideosComponent implements OnInit, AfterViewInit {
dataSource: VideosDataSource;
displayedColumns = [
'recorded_at',
'title',
'game',
'length'
];
@ViewChild(MatPaginator) paginator: MatPaginator;
@ViewChild(MatSort) sort: MatSort;
@ViewChild('input') input: ElementRef;
constructor(private route: ActivatedRoute,
private commentsService: CommentsService) { }
ngOnInit() {
this.dataSource = new VideosDataSource(this.commentsService);
this.dataSource.loadVideos('', 'recorded_at', 'desc', 0, 20);
}
ngAfterViewInit() {
this.sort.sortChange.subscribe(() => this.paginator.pageIndex = 0);
fromEvent(this.input.nativeElement, 'keyup')
.pipe(
debounceTime(150),
distinctUntilChanged(),
tap(() => {
this.paginator.pageIndex = 0;
this.loadVideosPage();
})
)
.subscribe();
merge(this.sort.sortChange, this.paginator.page)
.pipe(
tap(() => this.loadVideosPage())
)
.subscribe();
}
loadVideosPage() {
this.dataSource.loadVideos(
this.input.nativeElement.value,
this.sort.active,
this.sort.direction,
this.paginator.pageIndex,
this.paginator.pageSize);
}
}

@ -0,0 +1,3 @@
export const environment = {
production: true
};

@ -0,0 +1,8 @@
// The file contents for the current environment will overwrite these during build.
// The build system defaults to the dev environment which uses `environment.ts`, but if you do
// `ng build --env=prod` then `environment.prod.ts` will be used instead.
// The list of which env maps to which file can be found in `.angular-cli.json`.
export const environment = {
production: false
};

Binary file not shown.

After

Width:  |  Height:  |  Size: 10 KiB

@ -0,0 +1,18 @@
<!doctype html>
<html lang="en">
<head>
<meta charset="utf-8">
<title>Comments</title>
<base href="/comments/">
<meta name="viewport" content="width=device-width, initial-scale=1">
<link rel="icon" type="image/vnd.microsoft.icon" href="favicon.ico" sizes="16x16 32x32 48x48">
<link href="https://fonts.googleapis.com/icon?family=Material+Icons" rel="stylesheet">
<link href="https://fonts.googleapis.com/css?family=Roboto:300,400,500" rel="stylesheet">
</head>
<body>
<section class="mat-typography">
<app-root></app-root>
</section>
</body>
</html>

@ -0,0 +1,14 @@
import 'hammerjs';
import { enableProdMode } from '@angular/core';
import { platformBrowserDynamic } from '@angular/platform-browser-dynamic';
import { AppModule } from './app/app.module';
import { environment } from './environments/environment';
if (environment.production) {
enableProdMode();
}
platformBrowserDynamic().bootstrapModule(AppModule)
.catch(err => console.log(err));

@ -0,0 +1,79 @@
/**
* This file includes polyfills needed by Angular and is loaded before the app.
* You can add your own extra polyfills to this file.
*
* This file is divided into 2 sections:
* 1. Browser polyfills. These are applied before loading ZoneJS and are sorted by browsers.
* 2. Application imports. Files imported after ZoneJS that should be loaded before your main
* file.
*
* The current setup is for so-called "evergreen" browsers; the last versions of browsers that
* automatically update themselves. This includes Safari >= 10, Chrome >= 55 (including Opera),
* Edge >= 13 on the desktop, and iOS 10 and Chrome on mobile.
*
* Learn more in https://angular.io/docs/ts/latest/guide/browser-support.html
*/
/***************************************************************************************************
* BROWSER POLYFILLS
*/
/** IE9, IE10 and IE11 requires all of the following polyfills. **/
import 'core-js/es6/symbol';
import 'core-js/es6/object';
import 'core-js/es6/function';
import 'core-js/es6/parse-int';
import 'core-js/es6/parse-float';
import 'core-js/es6/number';
import 'core-js/es6/math';
import 'core-js/es6/string';
import 'core-js/es6/date';
import 'core-js/es6/array';
import 'core-js/es6/regexp';
import 'core-js/es6/map';
import 'core-js/es6/weak-map';
import 'core-js/es6/set';
/** IE10 and IE11 requires the following for NgClass support on SVG elements */
// import 'classlist.js'; // Run `npm install --save classlist.js`.
/** IE10 and IE11 requires the following for the Reflect API. */
import 'core-js/es6/reflect';
/** Evergreen browsers require these. **/
// Used for reflect-metadata in JIT. If you use AOT (and only Angular decorators), you can remove.
import 'core-js/es7/reflect';
/**
* Required to support Web Animations `@angular/platform-browser/animations`.
* Needed for: All but Chrome, Firefox and Opera. http://caniuse.com/#feat=web-animation
**/
// import 'web-animations-js'; // Run `npm install --save web-animations-js`.
/**
* By default, zone.js will patch all possible macroTask and DomEvents
* user can disable parts of macroTask/DomEvents patch by setting following flags
*/
// (window as any).__Zone_disable_requestAnimationFrame = true; // disable patch requestAnimationFrame
// (window as any).__Zone_disable_on_property = true; // disable patch onProperty such as onclick
// (window as any).__zone_symbol__BLACK_LISTED_EVENTS = ['scroll', 'mousemove']; // disable patch specified eventNames
/*
* in IE/Edge developer tools, the addEventListener will also be wrapped by zone.js
* with the following flag, it will bypass `zone.js` patch for IE/Edge
*/
// (window as any).__Zone_enable_cross_context_check = true;
/***************************************************************************************************
* Zone JS is required by default for Angular itself.
*/
import 'zone.js/dist/zone'; // Included with Angular CLI.
/***************************************************************************************************
* APPLICATION IMPORTS
*/

@ -0,0 +1 @@
/* You can add global styles to this file, and also import other style files */

@ -0,0 +1,20 @@
// This file is required by karma.conf.js and loads recursively all the .spec and framework files
import 'zone.js/dist/zone-testing';
import { getTestBed } from '@angular/core/testing';
import {
BrowserDynamicTestingModule,
platformBrowserDynamicTesting
} from '@angular/platform-browser-dynamic/testing';
declare const require: any;
// First, initialize the Angular testing environment.
getTestBed().initTestEnvironment(
BrowserDynamicTestingModule,
platformBrowserDynamicTesting()
);
// Then we find all the tests.
const context = require.context('./', true, /\.spec\.ts$/);
// And load the modules.
context.keys().map(context);

@ -0,0 +1,48 @@
@import '~@angular/material/theming';
@include mat-core();
$quotes-theme-foreground: (
base: white,
divider: rgba(#454d5d, 0.2),
dividers: rgba(#454d5d, 0.2),
disabled: $light-disabled-text,
disabled-button: rgba(white, 0.3),
disabled-text: $light-disabled-text,
hint-text: $light-disabled-text,
secondary-text: $light-secondary-text,
icon: white,
icons: white,
text: white,
slider-min: white,
slider-off: rgba(white, 0.3),
slider-off-active: rgba(white, 0.3),
);
$quotes-theme-background: (
status-bar: black,
app-bar: #303030,
background: #222,
hover: rgba(white, 0.04),
card: #222,
dialog: lighten(#222, 1%),
disabled-button: rgba(white, 0.12),
raised-button: map-get($mat-grey, 800),
focused-button: $light-focused,
selected-button: map_get($mat-grey, 900),
selected-disabled-button: map_get($mat-grey, 800),
disabled-button-toggle: black,
unselected-chip: map_get($mat-grey, 700),
disabled-list-option: black,
);
$quotes-theme: (
primary: mat-palette($mat-amber),
accent: mat-palette($mat-deep-orange),
warn: mat-palette($mat-red),
is-dark: true,
foreground: $quotes-theme-foreground,
background: $quotes-theme-background,
);
@include angular-material-theme($quotes-theme);

@ -0,0 +1,13 @@
{
"extends": "../tsconfig.json",
"compilerOptions": {
"outDir": "../out-tsc/app",
"baseUrl": "./",
"module": "es2015",
"types": []
},
"exclude": [
"test.ts",
"**/*.spec.ts"
]
}

@ -0,0 +1,19 @@
{
"extends": "../tsconfig.json",
"compilerOptions": {
"outDir": "../out-tsc/spec",
"baseUrl": "./",
"module": "commonjs",
"types": [
"jasmine",
"node"
]
},
"files": [
"test.ts"
],
"include": [
"**/*.spec.ts",
"**/*.d.ts"
]
}

@ -0,0 +1,5 @@
/* SystemJS module definition */
declare var module: NodeModule;
interface NodeModule {
id: string;
}

@ -0,0 +1,19 @@
{
"compileOnSave": false,
"compilerOptions": {
"outDir": "./dist/out-tsc",
"sourceMap": true,
"declaration": false,
"moduleResolution": "node",
"emitDecoratorMetadata": true,
"experimentalDecorators": true,
"target": "es5",
"typeRoots": [
"node_modules/@types"
],
"lib": [
"es2017",
"dom"
]
}
}

@ -0,0 +1,143 @@
{
"rulesDirectory": [
"node_modules/codelyzer"
],
"rules": {
"arrow-return-shorthand": true,
"callable-types": true,
"class-name": true,
"comment-format": [
true,
"check-space"
],
"curly": true,
"deprecation": {
"severity": "warn"
},
"eofline": true,
"forin": true,
"import-blacklist": [
true,
"rxjs",
"rxjs/Rx"
],
"import-spacing": true,
"indent": [
true,
"spaces"
],
"interface-over-type-literal": true,
"label-position": true,
"max-line-length": [
true,
140
],
"member-access": false,
"member-ordering": [
true,
{
"order": [
"static-field",
"instance-field",
"static-method",
"instance-method"
]
}
],
"no-arg": true,
"no-bitwise": true,
"no-console": [
true,
"debug",
"info",
"time",
"timeEnd",
"trace"
],
"no-construct": true,
"no-debugger": true,
"no-duplicate-super": true,
"no-empty": false,
"no-empty-interface": true,
"no-eval": true,
"no-inferrable-types": [
true,
"ignore-params"
],
"no-misused-new": true,
"no-non-null-assertion": true,
"no-shadowed-variable": true,
"no-string-literal": false,
"no-string-throw": true,
"no-switch-case-fall-through": true,
"no-trailing-whitespace": true,
"no-unnecessary-initializer": true,
"no-unused-expression": true,
"no-use-before-declare": true,
"no-var-keyword": true,
"object-literal-sort-keys": false,
"one-line": [
true,
"check-open-brace",
"check-catch",
"check-else",
"check-whitespace"
],
"prefer-const": true,
"quotemark": [
true,
"single"
],
"radix": true,
"semicolon": [
true,
"always"
],
"triple-equals": [
true,
"allow-null-check"
],
"typedef-whitespace": [
true,
{
"call-signature": "nospace",
"index-signature": "nospace",
"parameter": "nospace",
"property-declaration": "nospace",
"variable-declaration": "nospace"
}
],
"unified-signatures": true,
"variable-name": false,
"whitespace": [
true,
"check-branch",
"check-decl",
"check-operator",
"check-separator",
"check-type"
],
"directive-selector": [
true,
"attribute",
"app",
"camelCase"
],
"component-selector": [
true,
"element",
"app",
"kebab-case"
],
"no-output-on-prefix": true,
"use-input-property-decorator": true,
"use-output-property-decorator": true,
"use-host-property-decorator": true,
"no-input-rename": true,
"no-output-rename": true,
"use-life-cycle-interface": true,
"use-pipe-transform-interface": true,
"component-class-suffix": true,
"directive-class-suffix": true
}
}

@ -52,6 +52,10 @@ http {
root /quotes; root /quotes;
} }
location ^~ /comments/assets/ {
root /comments;
}
location ^~ /schedule/assets/ { location ^~ /schedule/assets/ {
root /schedule; root /schedule;
} }

Loading…
Cancel
Save