More

Author: user

lua/admin.lua

@@ -1,3 +1,7 @@
+-- Very limited "admin" interface via web.
+-- 
+-- Default password is "hello" so change that!
+-- 
 -- see: https://github.com/openresty/lua-nginx-module#nginx-api-for-lua
 
 -- must be before any content
@@ -12,7 +16,7 @@ if err then
 end
 
 local curpw, _ = config_table:get('passwd')
-ngx.log(ngx.INFO, 'PW = ' .. curpw)
+--ngx.log(ngx.INFO, 'PW = ' .. curpw)
 
 if args.pw ~= curpw  then
 	LOG("Wrong PW")

lua/pusher.lua

@@ -131,6 +131,9 @@ while true do
 				wb:send_ping('')
 			elseif msg == 'CLOSE' then
 				wb:send_close()
+			elseif msg == 'KILL' then
+				wb:send_close()
+				kill_session()
 			else
 				-- normal traffic on the channel; copy to websocket
 				local ok, err = wb:send_text(msg)

python/cfcapp.py

@@ -160,7 +160,7 @@ def ws_new_connection(self, wsid, fid):
 		rv.created()
 		return rv
 
-	def tx(self, msg, conn = None, fid=None, wsid=None, bcast=False):
+	def tx(self, msg, conn=None, fid=None, wsid=None, bcast=False):
 		'''
 			Send a message via websocket to a specific browser, specific tab (wsid) or all
 
@@ -185,17 +185,23 @@ def tx(self, msg, conn = None, fid=None, wsid=None, bcast=False):
 
 	def ws_close(self, wsid_or_conn):
 		'''
-			Close a specific web socket from server side; perhaps because it mis-behaved.
+			Close a specific web socket from server side.
 
 			LUA code detects this message and kills it's connection.
 		'''
 		self.tx('CLOSE', wsid=getattr(wsid_or_conn, 'wsid', wsid_or_conn))
 
+	def ws_kill(self, conn):
+		'''
+			Close all web sockets from server side; because user mis-behaved, and
+			also kill it's session on CFC. User will have to wait for javascript POW.
+		'''
+		self.tx('KILL', fid=conn.fid)
+
 	@setupmethod
 	def ws_rx_handler(self, f):
 		"""
 			Registers a function to be called when traffic is received via web sockets
-
 		"""
 		self.ws_rx_handlers.append(f)
 		return f

python/example_app.py

@@ -12,6 +12,7 @@ def rx_data(vhost, conn, msg):
 	app.tx(m, bcast=True)
 
 class Robot(object):
+	" Just a super-simple robot "
 	def __init__(self):
 		self.heard = set()
 
@@ -30,7 +31,7 @@ def rx_data(vhost, conn, msg):
 
 			user = conn.fid[-8:].upper()
 			if user not in self.heard:
-				m = {'from': 'Robot1', 'content': "Hello %s" % user}
+				m = {'from': 'Robot1', 'content': "Hello %s. Looking good!" % user}
 				app.tx(m, bcast=True)
 				self.heard.add(user)
 

python/templates/chat.html

@@ -26,7 +26,7 @@
 }
 
 #output {
-	max-height: 320px;
+	height: 320px;
 	overflow-y: scroll;
 }
 

python/upload.py

@@ -1,5 +1,14 @@
 #!/usr/bin/env python
 #
+# A program to demonstate how to upload a static website into the CFC. 
+#
+# You'd need to run it a few times:
+#	- upload content with "upload.py multi path-to-topdir"
+#	- commit that to disk in CFC: "upload.py write"
+#	- add some redirects, like root => index.html
+#	- 		./upload.py redirect / /index.html
+#
+#
 import os, sys, re, requests
 from redis import Redis
 import click