webif/var/mongoose/lib/epg.class

source /mod/webif/lib/setup

if {![exists -proc class]} { package require oo }
if {![exists -proc sqlite3.open]} { package require sqlite3 }

require settings.class progressbar rsv.class mwildcard

set ::epgpath /mnt/hd1/dvbepg/epg.dat
set ::epgdbpath /mnt/hd1/epg.db
set ::hdepgpath /media/drive1/epgsavedata
if {![file exists $::epgpath] && [file exists $::hdepgpath]} {
	set ::epgpath $::hdepgpath
	set ::epgdbpath /media/drive1/epg.db
}

set ::channeldb 0
set ::qepg 0
catch { set ::channeldb [sqlite3.open /var/lib/humaxtv/channel.db] }
if {[file exists $::epgdbpath]} {
	$::channeldb query {attach database '%s' as epg} $::epgdbpath
	set ::qepg 1
}

#  * service_id, event_id, start, duration, encrypted, name, text
#  * warning, content code, content type,
#  * event CRID, series CRID, rec CRID

class epg {
	service_id 	0
	event_id 	0
	start		0
	duration	0
	encrypted	0
	name		""
	text		""
	warning		""
	content_code	0
	content_type	""
	event_crid	""
	series_crid	""
	rec_crid	""

	channel_num	0
	channel_name	""
	channel_crid	""
	channel_hsvc	0

	sched_type	-1
	rsv		0
}

epg method _parse {line} {
	set vars [split $line "\t"]

	set service_id [lindex $vars 0]
	set event_id [lindex $vars 1]
	set start [lindex $vars 2]
	set duration [lindex $vars 3]
	set encrypted [lindex $vars 4]
	set name [lindex $vars 5]
	set text [lindex $vars 6]
	set warning [lindex $vars 7]
	set content_code [lindex $vars 8]
	set content_type [lindex $vars 9]
	set event_crid [lindex $vars 10]
	set series_crid [lindex $vars 11]
	set rec_crid [lindex $vars 12]
}

epg method percent {} {
	set now [clock seconds]
	if {$start > $now} { return 0 }
	if {$start + $duration < $now} { return 100 }
	return [expr [expr $now - $start] * 100 / $duration]
}

epg method showing {} {
	set now [clock seconds]
	if {$start > $now} { return 0 }
	if {$start + $duration < $now} { return 0 }
	return 1
}

epg method ended {} {
	if {$start + $duration < [clock seconds]} { return 1 }
	return 0
}

epg method elapsed {} {
	set percent [$self percent]
	if {$percent == 0} { return 0 }
	if {$percent == 100} { return $duration }
	return [expr $duration * $percent / 100]
}

epg method remaining {} {
	return [expr $duration - [$self elapsed]]
}

epg method type_icon {} {
	set img ""
	switch -- $content_code {
		1 { set img "Movie" }
		2 { set img "News" }
		3 { set img "Show" }
		4 { set img "Sports" }
		5 { set img "Children" }
		6 { set img "Music" }
		7 { set img "Art" }
		8 { set img "Society" }
		9 { set img "Education" }
		10 { set img "Leisure" }
	}
	if {$img != ""} {
		return "/images/173_3_00_G3_$img.png"
	} else {
		return ""
	}
}

proc {epg channelicon} {name {width 0} {style ""}} {
	set str "<img src=\"/img/channels/out/$name.png\"";
	if {$width > 0} { append str " width=$width" }
	if {$style ne ""} { append str " style=\"$style\" }
	append str " alt=\"\">"
	return $str
}

epg method channel_icon {{width 0} {style ""}} {
	set str "<img src=\"/img/channels/out/$channel_name.png\"";
	if {$width > 0} { append str " width=$width" }
	if {$style ne ""} { append str " style=\"$style\" }
	append str " alt=\"\">"
	return $str
}

epg method get_channel_info {} {
	global channeldb

	if {!$channel_num && $channeldb != ""} {
		set chan [lindex [$channeldb query {
			select szSvcName, usLcn, aucDefaultAuthority, hsvc
			from TBL_SVC
			where usSvcId = '%s'} $service_id
		    ] 0]
		if {[dict exists $chan usLcn]} {
			set channel_num $chan(usLcn)
			set channel_name [string range $chan(szSvcName) 1 end]
			set channel_crid [string toupper $chan(aucDefaultAuthority)]
			set channel_hsvc $chan(hSvc)
		}
	}
}

epg method copy_channel_info {s} {
	set channel_num [$s get channel_num]
	set channel_name [$s get channel_name]
	set channel_crid [$s get channel_crid]
	set channel_hsvc [$s get channel_hsvc]
}

epg method get_rsv {} {
	if {$hsvc == 0} { $self get_channel_info }
	if {$hsvc == 0} { return }

	if {$rsv == 0 && $event_crid ne ""} {
		set rsv [rsv entry $event_crid $hsvc]
	}
	if {$rsv == 0 && $series_crid ne ""} {
		set rsv [rsv entry $series_crid $hsvc]
	}
}

epg method process_sched {} {
	$self scheduled
}

set rsvlookup ""

epg method scheduled {} {
	global rsvlookup

	if {$sched_type >= 0} { return $sched_type }
	set sched_type 0

	if {$rsvlookup eq ""} {
		set rsvlookup [rsv lookuptab]
		#puts $rsvlookup
	}

	set p 0
	foreach key [list \
	    "$service_id:$event_id" \
	    [string tolower "$service_id:$channel_crid$series_crid"] \
	    [string tolower "$service_id:$channel_crid$event_crid"] \
	] {
		#puts "Check key ($key)"
		if {[dict exists $rsvlookup $key]} {
			set p $rsvlookup($key)
			#puts "FOUND ($p)"
			break
		}
	}

	switch $p {
	    S		{ set sched_type 2 }
	    E		{ set sched_type 1 }
	    default	{ set sched_type 0 }
	}

	#puts "SCHED_TYPE: ($sched_type)"

	return $sched_type
}

epg method icon_set {{height 0}} {
	if {$height > 0} { set height "height=$height" } else { set height "" }
	set icon [$self type_icon]
	set set ""
	if {$icon != ""} {
		lappend set "<img src=$icon $height
		    alt=\"$content_type\" title=\"$content_type\">"
	}

	$self process_sched
	if {$sched_type == 1} {
		lappend set \
		    "<img src=/images/175_1_11_Reservation_Record.png $height>"
	}

	if {$sched_type == 2} {
		lappend set \
		    "<img src=/images/175_1_11_Series_Record.png $height>"
	} elseif {$series_crid ne ""} {
		lappend set \
		    "<img src=/images/178_1_00_Icon_Serise.png $height>"
	}

	if {$rec_crid ne ""} {
		lappend set \
		    "<img src=/images/178_1_26_Icon_Recommend.png $height>"
	}

	if {[string match {/*#?} $event_crid]} {
		lappend set \
		    "<img src=/images/178_1_26_Icon_Split.png $height>"
	}

	return $set
}

epg method cell {} {
	set percent [$self percent]

	puts "<td nowrap valign=top>"

	puts [join [$self icon_set 14] ""]

	if {$series_crid ne ""} {
		set recopts 2
	} else {
		set recopts 1
	}

	puts "
	    <a class=event href=# xs=$service_id xe=$event_id
		sch=$sched_type rec=$recopts>
	    $name</a>
	"

	puts "<br>"

	puts "<font class=footnote>"
	puts "[clock format $start -format %H:%M]"
	puts " ([clock format $duration -format %T])"
	if {$percent > 0 && $percent < 100} {
		puts "<br>[progressbar $percent]"
		puts "$percent% [clock format [$self elapsed] -format %T] /
		      [clock format [$self remaining] -format %T]"
	}
	puts "</font>"
	puts "</td>"
}

epg method next {} {
	set tm $($start + $duration + 60)
	set nextlist [epg fetch dump -service $service_id -time $tm]

	if {[llength nextlist] > 0} {
		return [lindex $nextlist 0]
	} else {
		return ""
	}
}

epg method previous {} {
	set tm $($start - 60)
	set prevlist [epg fetch dump -service $service_id -time $tm]

	if {[llength prevlist] > 0} {
		return [lindex $prevlist 0]
	} else {
		return ""
	}
}

epg method recommended {} {
	set rec ""
	if {$rec_crid ne ""} {
		catch { set rec [lindex [
		    epg fetch dump -crid $rec_crid] 0] }
	}
	return $rec
}

epg method othertimes {} {
	if {$event_crid eq ""} { return "" }

	set others ""
	foreach other [epg fetch dump -crid $event_crid] {
		if {[$other get service_id] == $service_id &&
		    [$other get event_id] == $event_id} { continue }
		lappend others $other
	}
	return $others
}

proc {epg parse} {line} {
	set e [epg new]
	$e _parse $line
	return $e
}

proc {epg cleanup} {} {
	global channeldb

	if {$channeldb != ""} { $channeldb close }
}

proc {epg exec} {mode args} {
	set raw 0
	set cmd [list /mod/bin/epg -f $::epgpath]
	set extra ""
	foreach arg $args {
		if {[string first "-" $arg] == 0} {
			switch -- $arg {
				-raw { set raw 1 }
				-crid { lappend cmd -C $args($arg) }
				-scrid { lappend cmd -R $args($arg) }
				-type { lappend cmd -T $args($arg) }
				-service { lappend cmd -S $args($arg) }
				-event { lappend cmd -E $args($arg) }
				-time { lappend cmd -@ $args($arg) }
				-trange { lappend cmd -= $args($arg) }
				-day { lappend cmd -/ $args($arg) }
				-extra { set extra $args($arg) }
				default { error "Invalid option, $arg" }
			}
		}
	}
	if { $raw == 0 } { lappend cmd -p }
	lappend cmd $mode
	lappend cmd $extra

	#puts "CMD -$cmd-"

	return [exec {*}$cmd]
}

proc {epg dbfetch} {mode args} {
	set records {}
	set extra ""
	set params {}

	set select "
	    select distinct *,
	    usLcn as channel_num,
	    substr(szSvcName, 2) as channel_name,
	    aucDefaultAuthority as channel_crid,
	    hSvc as channel_hsvc
	"

	set from "
	    from epg.epg e join TBL_SVC c
	    on e.service_id = c.usSvcId
	"

	set q "where 1 "

	set sort "order by channel_num, start"

	foreach arg $args {
		if {[string first "-" $arg] == 0} {
			set v $args($arg)
			switch -- $arg {
				-crid { append q \
				    "and e.event_crid = '$v' " }
				-scrid { append q \
				    "and e.series_crid = '$v' " }
				-type { append q \
				    "and e.content_type = $v " }
				-service { append q \
				    "and e.service_id = $v " }
				-event { append q \
				    "and e.event_id = $v " }
				-time { append q \
				    "and e.start < $v and e.end > $v " }
				-after { append q \
				    "and e.end >= $v " }
				-trange {
					lassign [split $v :] stt ett
					append q "and (
					(e.start > $stt and e.start < $ett) or
					(e.end > $stt and e.end < $ett) or
					(e.start < $stt and e.end > $stt)
					) "
				}
				-fav {
					append from \
					    "join TBL_FAV f using(hSvc) "
					append q "and f.eFavGroup = $v "
					set sort "order by f.favIdx, start"
				}
				-term {
					set v [mwildcard $v]
					append q "and ("
					append q "e.name like '%s' "
					lappend params "%$v%"
					if {$mode eq "searchall"} {
						append q \
						    "or e.text like '%s' "
						lappend params "%$v%"
					}
					append q ") "
                                }
				default { error "Invalid option, $arg" }
			}
		}
	}

	set query "$select $from $q $sort"

	#puts "QUERY -$query-"

	set records {}
	if {[catch {
		foreach rec [$::channeldb query $query {*}$params] {
			lappend records [epg new $rec]
		}
	} msg]} {
		puts "No cached EPG data, try again later ($msg)."
	}
	return $records
}

proc {epg fetch} {mode args} {
	set records ""
	foreach line [split [epg exec $mode {*}$args] "\n"] {
		lappend records [epg parse $line]
	}
	return $records
}

proc {epg favlist} {} {
	global channeldb

	set num [[settings] channel_group]

	if {!$num} { return "" }

	return [lmap i [$channeldb query "
		select TBL_SVC.usSvcid
		from TBL_SVC join TBL_FAV
		using(hSvc)
		where TBL_FAV.eFavGroup == $num
		order by TBL_FAV.favIdx
	"] { lindex $i end }]
}

proc {epg channellist} {{field usLcn}} {
	global channeldb

	set channels {}
	lmap i [$channeldb query "
		select $field, szSvcName
		from TBL_SVC
		order by 1
	"] { lappend channels [list \
	    [string range [lindex $i 3] 1 end] [lindex $i 1] ] }

	return $channels
}