import org.serviio.library.metadata.* import org.serviio.library.online.* import org.serviio.util.* import java.io.FileInputStream import java.util.zip.GZIPInputStream /******************************************************************** * coolsport plugin for Serviio * * @author JHB50 * * URL to use as video webresource: http://www.coolsport.tv/ * * Also displays next 2 scheduled events for each channel * For complete schedule see http://www.coolsport.tv/ * * Version: * V1: - Nov 25, 2012 - Initial Release * V2: - Dec 1, 2012 - Add dummy item if no feed items found * V3: - Dec 5, 2012 - new time parameter * V4: - Dec 7, 2012 - correct parameter processing * V5: - Dec 8, 2012 - new web format * V6: - Dec 9, 2012 - correct local time calculation * V7: - Dec 16, 2012 - Add AM PM events, channel to title, fix incorrect 12:00PM * V8: - Dec 17, 2012 - another new web format * V9: - Dec 31, 2012 - verify network active before parsing * V10 - Jan 1, 2013 - add sched=1 option for slow cpus. * V11 - Jan 10, 2013 - another new web format * V12 - Feb 3, 2013 - Genurls added by default to minimize extracts * V13 - Feb 4, 2013 - Fix bug * V14 - Feb 5, 2013 - Add timeout timer, put time first * V15 - Feb 10, 2013 - Skip ch25 which never works * V16 - Feb 11, 2013 - Only show language if its not ENGLISH * V17 - Feb 18, 2013 - Add Custom channels * V18 - Mar 8, 2013 - Increase Extract Timeout to 90 seconds * V19 - Mar 18, 2013 - Support KiwiSportz * V20:- Mar.27, 2013 - update sources * V21:- Apr.19, 2013 - Update icons * ********************************************************************/ class Coolsport extends WebResourceUrlExtractor { long StartETime = 0 long LastETime2 = 0 long LastETime3 = 0 List newitems = [] List olditems = [] final VALID_RESOURCE_URL = '^http://www.coolsport.tv.*?' String getExtractorName() { return 'coolsport' } boolean extractorMatches(URL resourceUrl) { return resourceUrl ==~ VALID_RESOURCE_URL } int getVersion() { return 21 } int getExtractItemsTimeout() { return 90 } Long ETimer(String msg){ long CurrentTime = System.currentTimeMillis() long Elapsed = CurrentTime - StartETime if (msg != null){ log("$msg = $Elapsed msec") } return Elapsed } Long ETimer2(String msg){ long CurrentTime = System.currentTimeMillis() long Elapsed = CurrentTime - LastETime2 LastETime2 = CurrentTime if (msg != null){ log("$msg = $Elapsed msec") } return Elapsed } Long ETimer3(String msg){ long CurrentTime = System.currentTimeMillis() long Elapsed = CurrentTime - LastETime3 LastETime3 = CurrentTime if (msg != null){ log("$msg = $Elapsed msec") } return Elapsed } Boolean URLExists(String srcURL){ URL fileURL = new URL(srcURL); if(((HttpURLConnection) fileURL.openConnection()).getResponseCode() == 404){ return false } return true } String OpenProtURL(String srcURL,String Referrer) { def rv = "" URL url = new URL(srcURL); URLConnection conn = url.openConnection(); conn.setRequestProperty("Referer", Referrer); conn.setDoOutput(true); BufferedReader rd = new BufferedReader(new InputStreamReader(conn.getInputStream())); String line; while ((line = rd.readLine()) != null) { rv += line } rd.close(); return rv } Boolean channelOffline( String htmlText, String offlineChecker ) { def offline_check = htmlText =~ offlineChecker if (offline_check.count > 0) { return true } return false } Boolean streamNotSupported( String htmlText, String streamNotSupportedChecker ) { def notsupported_check = htmlText =~ streamNotSupportedChecker if (notsupported_check.count > 0) { return true } return false } WebResourceContainer extractItems(URL resourceUrl, int maxItemsToRetrieve) { log("Parsing with Coolsport V${getVersion()}") StartETime = System.currentTimeMillis() ETimer2() def genurls = 1 def curDate = new Date(System.currentTimeMillis()+300000) olditems = [] if (newitems){ def newitemssize = newitems.size() def nli = newitems.iterator() while (nli.hasNext()){ def newEntry = nli.next() if(newEntry.getAdditionalInfo()['XexpiresImmediately']!= true) continue def SavedExpiryDate = newEntry.getAdditionalInfo()['XexpiresOn'] if(SavedExpiryDate > new Date(0) && curDate >= SavedExpiryDate) continue olditems << newEntry } def olditemssize = olditems.size() log ( olditemssize + " items saved, " + (newitemssize - olditemssize) + " expired" ) olditems = olditems.drop(olditemssize-300) newitems = olditems } while(1) { def test_text = openURL(new URL("http://www.dogpile.com"), "Mozilla/5.0 (Windows NT 6.1) AppleWebKit/537.1 (KHTML, like Gecko) Chrome/21.0.1180.83 Safari/537.1") def testMatch = test_text ==~ '(?s).*?Dogpile Web Search.*?' if (testMatch) break } List items = [] short time = 0 def itemsAdded = 0 def channel_image = "" def srcUrl = "" def channel_title_text = "" long Refreshi = 0 long Refresha = 0 def sched = 2 def noevents = 0 def parmMatcher = resourceUrl =~ '^http://www.coolsport\\.tv.*?genurls=([0-1])' def parmMatch = resourceUrl ==~ '^http://www.coolsport\\.tv.*?genurls=[0-1].*?' if (parmMatch){ genurls = parmMatcher[0][1].trim() } parmMatcher = resourceUrl =~ '^http://www.coolsport\\.tv.*?noevents=1' parmMatch = resourceUrl ==~ '^http://www.coolsport\\.tv.*?noevents=1.*?' if (parmMatch){ noevents = 1 } parmMatcher = resourceUrl =~ '^http://www.coolsport\\.tv.*?refresh=([0-9]+)' parmMatch = resourceUrl ==~ '^http://www.coolsport\\.tv.*?refresh=[0-9]+.*?' if (parmMatch){ Refreshi = parmMatcher[0][1].trim().toLong() long curTime=System.currentTimeMillis()/60000 Refresha = (System.currentTimeMillis()/60000) + Refreshi + 5 } parmMatcher = resourceUrl =~ '^http://www.coolsport.tv.*?sched=1' parmMatch = resourceUrl ==~ '^http://www.coolsport.tv.*?sched=1.*?' if (parmMatch){ sched = 1 } parmMatcher = resourceUrl =~ '^http://www.coolsport.tv.*?time=([0-9]+)' parmMatch = resourceUrl ==~ '^http://www.coolsport.tv.*?time=[0-9]+.*?' if (parmMatch){ time = parmMatcher[0][1].trim().toShort() if (time < 0 || time > 24) time = 0 } def resource_text = openURL(new URL("http://www.coolsport.tv/schedule.html"), "Mozilla/5.0 (Windows NT 6.1) AppleWebKit/537.1 (KHTML, like Gecko) Chrome/21.0.1180.83 Safari/537.1") //def SCHEDULE_LIST_EXTRACTOR = '\\*(.*?)(\\d+)[:\\.,](\\d\\d)(.[mM])-(\\d+)[://.,](\\d\\d)(.[mM]).*?Stream.(.*?)

This channel is offline\\.

') || channelOffline(srcUrl_text, '

') ) { log (srcUrl + " is OFFLINE") return null } if (streamNotSupported(srcUrl_text, '') ) { log (srcUrl + " is NOTSUPPORTED") return null } def linkMatcher = srcUrl_text =~ '(?s)
.?src=["\']http://sawlive.tv/embed/(.?)["\']' idMatched = srcUrl_text ==~ '(?s).*? rtmpUrl = "rtmp://37.220.34.59:1935/liverepeater/_definst_/" + idMatcher[0][1] + " live=1" } else if(idMatcher[0][2].contains("coolsport.tv/livegame.js")) { srcUrl = "http://embeds.coolsport.tv/livegame.php?id=" + idMatcher[0][1] + "&width=640&height=460" log("Source Link 3: $srcUrl") srcUrl_text = openURL(new URL(srcUrl), "Mozilla/5.0 (Windows NT 6.1) AppleWebKit/537.1 (KHTML, like Gecko) Chrome/21.0.1180.83 Safari/537.1") idMatcher = srcUrl_text =~ '(?s)