@@ -12,7 +12,7 @@ much about server administration. PREREQUISITES * Google App Engine -* Flex Builder or Flex SDK +* Flex Builder 3 or Flex SDK * Python 2.5 INSTRUCTIONS README.txt @@ -1,4 +1,6 @@ Features: +* Support delete operation. +* Make a better use of objects on the Flex side. * Integrate user authentication on the Flex client and the GAE server. * Use the RESTful convention. TODO.txt flex-client/bin-debug/main.swf @@ -1,69 +1,85 @@ <?xml version="1.0" encoding="utf-8"?> <mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute" creationComplete="onInit()"> <mx:Script> - <![CDATA[ - import flash.net.Responder; - import mx.controls.Alert; + <![CDATA[ + import flash.net.Responder; + import mx.controls.Alert; + import mx.utils.ObjectUtil; - [Bindable] - public var dataProvider:Array; + [Bindable] + public var dataProvider:Array; - [Bindable] - public var statusMsg:String; + [Bindable] + public var statusMsg:String; + + [Bindable] + public var project:Object; - public var gateway:NetConnection; - - public function onInit():void - { - statusMsg = "Loading data..."; - gateway = new NetConnection(); - gateway.connect("http://localhost:8080/"); - getProjects(); - } - - public function getProjects():void { - gateway.call("ProjectService.get_all", new Responder(getResult, onFault)); - } + public var gateway:NetConnection; + + public function onInit():void { + statusMsg = "Loading data..."; + gateway = new NetConnection(); + gateway.connect("http://localhost:8080/"); + getProjects(); + } + + public function getProjects():void { + gateway.call("ProjectService.get_all", new Responder(getResult, onFault)); + } - public function getResult(result:Array):void { - dataProvider = result; - statusMsg = "Data loaded."; - } + public function getResult(result:Array):void { + dataProvider = result; + statusMsg = "Data loaded."; + } - public function submitProject():void { - var newProject:Object = new Object(); - newProject.code = project_code.text; - newProject.name = project_name.text; - gateway.call("ProjectService.insert", new Responder(null, onFault), newProject); - getProjects(); - } + public function submitProject():void { + var newProject:Object = new Object(); + newProject.code = project_code.text; + newProject.name = project_name.text; + newProject._key = project._key; + gateway.call("ProjectService.save", new Responder(null, onFault), newProject); + getProjects(); + } - public function onFault(info:Object):void { - statusMsg = info.toString(); - } - ]]> + public function onFault(info:Object):void { + statusMsg = info.toString(); + } + + public function ProjectGridChanged():void { + project = ObjectUtil.copy(dgProjects.selectedItem); + } + + public function AddNewProjectClicked():void { + project = new Object(); + project.code = null; + project.name = null; + project.created_at = null; + project.modified_at = null; + project._key = null; + project_code.setFocus(); + } + ]]> </mx:Script> - <mx:DataGrid id="dgProjects" x="10" y="10" dataProvider="{dataProvider}" width="356" height="183"> - <mx:columns> - <mx:DataGridColumn headerText="Code" dataField="code"/> - <mx:DataGridColumn headerText="Name" dataField="name"/> - </mx:columns> - </mx:DataGrid> - <mx:Button x="374" y="11" label="Reload" click="onInit()"/> - <mx:Label x="10" y="203" text="Created at"/> - <mx:TextInput x="103" y="201" id="selected_created_at" text="{dgProjects.selectedItem.created_at}" width="263"/> - <mx:Form x="10" y="240" width="356" borderStyle="solid" cornerRadius="2"> - <mx:FormHeading label="New Project"/> - <mx:HBox> - <mx:Label text="Code"/> - <mx:TextInput id="project_code" width="159"/> - </mx:HBox> - <mx:HBox> - <mx:Label text="Name"/> - <mx:TextInput id="project_name"/> - </mx:HBox> - <mx:Button label="Insert" click="submitProject()"/> - </mx:Form> - <mx:Label x="10" y="384" text="{statusMsg}" width="356"/> + <mx:DataGrid id="dgProjects" x="10" y="10" dataProvider="{dataProvider}" width="356" height="183" change="ProjectGridChanged()"> + <mx:columns> + <mx:DataGridColumn headerText="Code" dataField="code"/> + <mx:DataGridColumn headerText="Name" dataField="name"/> + </mx:columns> + </mx:DataGrid> + <mx:Button x="374" y="11" label="Refresh" click="onInit()"/> + <mx:Button x="374" y="41" label="Add new project" click="AddNewProjectClicked()"/> + <mx:HRule x="10" y="201" width="356"/> + <mx:TextInput id="project_code" width="261" x="105" y="209" text="{project.code}"/> + <mx:Label text="Code" x="10" y="211"/> + <mx:TextInput id="project_name" x="105" y="239" width="261" text="{project.name}"/> + <mx:Label text="Name" x="10" y="241"/> + <mx:Label x="10" y="271" text="Created at"/> + <mx:TextInput x="105" y="269" id="selected_created_at" text="{project.created_at}" width="261" editable="false"/> + <mx:Label x="12" y="297" text="Modified at"/> + <mx:TextInput x="105" y="299" width="261" text="{project.modified_at}" editable="false"/> + <mx:Button label="Save" click="submitProject()" x="374" y="299"/> + <mx:HRule x="10" y="323" width="356" height="8"/> + <mx:Label x="10" y="339" text="{statusMsg}" width="356"/> </mx:Application> flex-client/src/main.mxml @@ -8,10 +8,13 @@ client.py insert 1 "Project name" Inserts a new project with code = 1 and name = "Project name". client.py get 1 Gets a project with code = 1. +client.py update 1 "New project name" + Updates the name on the project with code = 1. client.py all Lists all projects. """ +from pprint import pprint import sys from pyamf.remoting.client import RemotingService @@ -32,7 +35,16 @@ def insert(code, name): "code": int(code), "name": name, } - service.insert(new_project) + project = service.save(new_project) + print_project(project) + +def update(code, name): + gw = RemotingService('http://localhost:8080/') + service = gw.getService('ProjectService') + project = service.get(int(code)) + project.name = name + project = service.save(project) + print_project(project) def get(code): gw = RemotingService('http://localhost:8080/') @@ -51,7 +63,7 @@ def all(): print_project(project) def print_project(project): - print "Project code = %s, name = %s, created at %s" % (project.code, project.name, project.created_at) + pprint(project) def main(args): if len(args) == 0: @@ -64,6 +76,8 @@ def main(args): insert(args[1], args[2]) elif command == 'get' and len(args) == 2: get(args[1]) + elif command == 'update' and len(args) == 3: + update(args[1], args[2]) elif command == 'all' and len(args) == 1: all() else: python-client/client.py @@ -27,10 +27,7 @@ def writeObjectAMF0(self, obj, *args, **kwargs): remove = True self.context.class_aliases[obj.__class__] = pyamf.ClassAlias(obj.__class__, None) - self.writeObject(obj, *args, **kwargs) - - if remove: - self.context.class_aliases[obj.__class__] = None + writeObjectAMF(self, obj, args, kwargs, remove) def writeObjectAMF3(self, obj, *args, **kwargs): try: @@ -45,8 +42,18 @@ def writeObjectAMF3(self, obj, *args, **kwargs): alias = pyamf.ClassAlias(obj.__class__, None) self.context.class_aliases[obj.__class__] = alias - self.writeObject(obj, *args, **kwargs) + writeObjectAMF(self, obj, args, kwargs, remove) +def writeObjectAMF(self, obj, args, kwargs, remove): + """ + Writes an object that has already been prepared by writeObjectAMF0 or writeObjectAMF3. + """ + try: + obj._key = str(obj.key()) + except: + obj._key = None + self.writeObject(obj, *args, **kwargs) + del obj._key if remove: self.context.class_aliases[obj.__class__] = None @@ -54,13 +61,13 @@ def get_attrs_for_model(obj): """ Returns a list of properties on an C{db.Model} instance. """ - return list(obj.__class__._properties) + return list(obj.__class__._properties) + ['_key'] def get_attrs_for_expando(obj): """ Returns a list of dynamic properties on a C{db.Expando} instance. """ - return obj.dynamic_properties() + return obj.dynamic_properties() + ['_key'] pyamf.register_class(db.Model, attr_func=get_attrs_for_model, metadata=['dynamic']) pyamf.register_class(db.Expando, attr_func=get_attrs_for_expando, metadata=['dynamic']) python-client/pyamf/adapters/_google_appengine_ext_db.py @@ -27,10 +27,7 @@ def writeObjectAMF0(self, obj, *args, **kwargs): remove = True self.context.class_aliases[obj.__class__] = pyamf.ClassAlias(obj.__class__, None) - self.writeObject(obj, *args, **kwargs) - - if remove: - self.context.class_aliases[obj.__class__] = None + writeObjectAMF(self, obj, args, kwargs, remove) def writeObjectAMF3(self, obj, *args, **kwargs): try: @@ -45,8 +42,18 @@ def writeObjectAMF3(self, obj, *args, **kwargs): alias = pyamf.ClassAlias(obj.__class__, None) self.context.class_aliases[obj.__class__] = alias - self.writeObject(obj, *args, **kwargs) + writeObjectAMF(self, obj, args, kwargs, remove) +def writeObjectAMF(self, obj, args, kwargs, remove): + """ + Writes an object that has already been prepared by writeObjectAMF0 or writeObjectAMF3. + """ + try: + obj._key = str(obj.key()) + except: + obj._key = None + self.writeObject(obj, *args, **kwargs) + del obj._key if remove: self.context.class_aliases[obj.__class__] = None @@ -54,13 +61,13 @@ def get_attrs_for_model(obj): """ Returns a list of properties on an C{db.Model} instance. """ - return list(obj.__class__._properties) + return list(obj.__class__._properties) + ['_key'] def get_attrs_for_expando(obj): """ Returns a list of dynamic properties on a C{db.Expando} instance. """ - return obj.dynamic_properties() + return obj.dynamic_properties() + ['_key'] pyamf.register_class(db.Model, attr_func=get_attrs_for_model, metadata=['dynamic']) pyamf.register_class(db.Expando, attr_func=get_attrs_for_expando, metadata=['dynamic']) server/pyamf/adapters/_google_appengine_ext_db.py @@ -1,3 +1,6 @@ +# http://www.nabble.com/Python-Django-Google-App-Engine-De-serialization-Issue-td18221229.html +# obj_to_gae + import logging from google.appengine.ext import db @@ -5,6 +8,7 @@ class Project(db.Model): code = db.IntegerProperty() name = db.StringProperty() created_at = db.DateTimeProperty(auto_now_add=True) + modified_at = db.DateTimeProperty(auto_now=True) class ProjectService: def get(self, code): @@ -18,6 +22,21 @@ class ProjectService: new_project.code = int(project.code) new_project.name = project.name new_project.put() + return new_project + + def update(self, project): + logging.debug('udpate %s' % (project)) + existing_project = Project.get(project._key) + existing_project.name = project.name + existing_project.put() + return Project.get(project._key) + + def save(self, project): + logging.debug('save %s' % (project)) + if hasattr(project, '_key') and project._key != None: + return self.update(project) + else: + return self.insert(project) def get_all(self): logging.debug('get_all') server/services/ProjectService.py b6e7458d6ecb037f1dc1293fccc2a7d3c15a5b93 Fernando Correia fernandoacorreia@gmail.com http://github.com/fernandoacorreia/flex-and-python-test/commit/25770d9289ba2410668f00310d57ea51a0b6b97c 25770d9289ba2410668f00310d57ea51a0b6b97c 2008-07-19T17:47:27-07:00 2008-07-19T17:47:27-07:00 support for updating objects 8c6d6ac7105e2d5c726a0defade0544c34817afe Fernando Correia fernandoacorreia@gmail.com