Added support for FloSports

README.md

@@ -2,7 +2,7 @@
   <img src="https://i.imgur.com/FIGZdR3.png">
 </p>
 
-Current version: **2.2.0**
+Current version: **2.3.0**
 
 # About
 This takes ESPN/ESPN+, FOX Sports, Paramount+, MSG+, B1G+, or MLB.tv programming and transforms it into a "live TV" experience with virtual linear channels. It will discover what is on, and generate a schedule of channels that will give you M3U and XMLTV files that you can import into something like [Jellyfin](https://jellyfin.org) or [Channels](https://getchannels.com).
@@ -66,6 +66,12 @@ Use if you would like to login with Paramount+
 |---|---|---|---|
 | PARAMOUNTPLUS | Set if you would like CBS Sports events | False | False |
 
+#### FloSports
+Use if you would like to login with FloSports
+| Environment Variable | Description | Required? | Default |
+|---|---|---|---|
+| FLOSPORTS | Set if you would like FloSports events | False | False |
+
 #### B1G+
 Use if you would like to login with your B1G+ account
 | Environment Variable | Description | Default |

index.ts

@@ -10,6 +10,7 @@ import {espnHandler} from './services/espn-handler';
 import {foxHandler} from './services/fox-handler';
 import {mlbHandler} from './services/mlb-handler';
 import {b1gHandler} from './services/b1g-handler';
+import {floSportsHandler} from './services/flo-handler';
 import {paramountHandler} from './services/paramount-handler';
 import {msgHandler} from './services/msg-handler';
 import {cleanEntries, removeChannelStatus} from './services/shared-helpers';
@@ -34,6 +35,7 @@ const schedule = async () => {
   await foxHandler.getSchedule();
   await mlbHandler.getSchedule();
   await b1gHandler.getSchedule();
+  await floSportsHandler.getSchedule();
   await paramountHandler.getSchedule();
   await msgHandler.getSchedule();
 
@@ -214,6 +216,9 @@ process.on('SIGINT', shutDown);
   await b1gHandler.initialize();
   await b1gHandler.refreshTokens();
 
+  await floSportsHandler.initialize();
+  await floSportsHandler.refreshTokens();
+
   await paramountHandler.initialize();
   await paramountHandler.refreshTokens();
 
@@ -237,6 +242,7 @@ setInterval(async () => {
   await foxHandler.refreshTokens();
   await mlbHandler.refreshTokens();
   await b1gHandler.refreshTokens();
+  await floSportsHandler.refreshTokens();
   await paramountHandler.refreshTokens();
   await msgHandler.refreshTokens();
 }, 1000 * 60 * 30);

package.json

@@ -1,6 +1,6 @@
 {
   "name": "eplustv",
-  "version": "2.2.0",
+  "version": "2.3.0",
   "description": "",
   "scripts": {
     "start": "ts-node index.ts",

services/b1g-handler.ts

@@ -101,7 +101,7 @@ const parseAirings = async (events: IB1GEvent[]) => {
 
       if (!entryExists) {
         const start = moment(event.startTime);
-        const end = moment(event.startTime).add(5, 'hours');
+        const end = moment(event.startTime).add(4, 'hours');
 
         if (end.isBefore(now) || content.enableDrmProtection) {
           continue;

services/build-schedule.ts

@@ -1,7 +1,5 @@
-import fs from 'fs';
-
 import {NUM_OF_CHANNELS, START_CHANNEL} from './channels';
-import {db, IDocument, linearDb} from './database';
+import {db, IDocument} from './database';
 import {IChannel, IEntry} from './shared-interfaces';
 
 const scheduleEntry = async (entry: IEntry & IDocument, startChannel: number): Promise<void> => {
@@ -34,41 +32,11 @@ const scheduleEntry = async (entry: IEntry & IDocument, startChannel: number): P
 };
 
 export const scheduleEntries = async (): Promise<void> => {
-  let needReschedule = false;
-
-  try {
-    // Check to see if we still have linear channels scheduled
-    const linearChannelNums = await db.linear?.remove({}, {multi: true});
-
-    if (linearChannelNums > 0) {
-      needReschedule = true;
-      fs.rmSync(linearDb);
-    }
-  } catch (e) {}
-
-  if (needReschedule) {
-    console.log('');
-    console.log('====================================================================');
-    console.log('===                                                              ===');
-    console.log('=== Need to rebuild the schedule because the USE_LINEAR variable ===');
-    console.log('===                   is no longer being used.                   ===');
-    console.log('===                                                              ===');
-    console.log('====================================================================');
-    console.log('===  THIS WILL BREAK SCHEDULED RECORDINGS IN YOUR DVR SOFTWARE   ===');
-    console.log('====================================================================');
-    console.log('');
+  const unscheduledEntries = await db.entries.find<IEntry>({channel: {$exists: false}}).sort({start: 1});
 
-    await db.entries.update<IEntry>({}, {$unset: {channel: true}}, {multi: true});
-    await db.schedule.remove({}, {multi: true});
+  unscheduledEntries.length > 0 && console.log(`Scheduling ${unscheduledEntries.length} entries...`);
 
-    return await scheduleEntries();
-  } else {
-    const unscheduledEntries = await db.entries.find<IEntry>({channel: {$exists: false}}).sort({start: 1});
-
-    unscheduledEntries.length > 0 && console.log(`Scheduling ${unscheduledEntries.length} entries...`);
-
-    for (const entry of unscheduledEntries) {
-      await scheduleEntry(entry, START_CHANNEL);
-    }
+  for (const entry of unscheduledEntries) {
+    await scheduleEntry(entry, START_CHANNEL);
   }
 };