praveen001

package controllers

import (
	"fmt"
	"net/http"

	"github.com/techinscribed/repository-db/models"
)

// BaseHandler will hold everything that controller needs

praveen001

import React, { useContext } from 'react';
import { Button } from '@material-ui/core';
import { ThemeContext} from './ThemeProvider';

const App: React.FC = () => {
  // Get the setter function from context
  const setThemeName = useContext(ThemeContext)

  return (
    <div className="App">

praveen001

{
  "semi": true,
  "singleQuote": true,
  "trailingComma": "none",
  "tabWidth": 2,
  "useTabs": false,
  "bracketSpacing": true
}

praveen001

import { withAuthenticator } from 'aws-amplify-react';

function App() {
   return (
      ...
   )
}

export default withAuthenticator(App, {
  includeGreetings: true

praveen001

import { ADD_TODO, REMOVE_TODO } from '../actions/todos';

const changes = {};
let currentVersion = -1;
const noOfVersionsSupported = 100;
const undoableActions = [ADD_TODO, REMOVE_TODO];

export default function(state = initialState, action) {
  return produce(state, draft => {
    // ... code removed for brevity

praveen001

{
  "editor.multiCursorModifier": "ctrlCmd",
  "editor.snippetSuggestions": "bottom",
  "window.zoomLevel": 0,
  "workbench.colorCustomizations": {
    "statusBar.background": "#000",
    "statusBar.border": "#222",
    "statusBar.foreground": "#02bb7d",

    "sideBar.background": "#081014",

praveen001

const disconnectEpic = (action$, state$: StateObservable<IState>) =>
  action$
    .ofType(WebsocketActionTypes.DISCONNECT)
    .mergeMap((action: IDisconnectFromWebsocketAction) => {
      if (action.payload.retry) {
        return of(connect(state$.value.config.webSocketURL)) // <-- reconnect
          .delay(5000)
          .startWith(disconnected());
      }
      onCloseSubject.complete();

praveen001

const connectEpic = (action$, state$: StateObservable<IState>) =>
  action$
    .ofType(WebsocketActionTypes.CONNECT)
    .switchMap((action: IConnectWebsocketAction) =>
      connectSocket(state$.value.eventConfig.webSocketURL)
        .map(data => receiveMessageFromWebSocket(data)) // <-- Map and fire receive action
    );

praveen001

// Detect successfull connection by listening to onOpenSubject
const connectedEpic = action$ =>
  action$.ofType(WebsocketActionTypes.CONNECT).switchMap(() =>
    onOpenSubject.map(() => {
      return connected();
    })
  );

praveen001

import { combineEpics, StateObservable } from 'redux-observable';
import { of } from 'rxjs';
import { Subject } from 'rxjs/Subject';
import { webSocket, WebSocketSubject } from 'rxjs/webSocket';
import {
  connected,
  connect,
  disconnected,
  disconnect,
  IConnectWebsocketAction,