add toDictionary, toJSONString

Sources/RxCodable/Maybe+RxCodable.swift

@@ -18,3 +18,30 @@ public extension PrimitiveSequenceType where TraitType == MaybeTrait, ElementTyp
   }
 }
 
+public extension PrimitiveSequenceType where TraitType == MaybeTrait, ElementType == [String: Any] {
+  public func map<T>(_ type: T.Type, using decoder: JSONDecoder? = nil) -> PrimitiveSequence<TraitType, T> where T: Decodable {
+    return self
+      .map { dict in try JSONSerialization.data(withJSONObject: dict) }
+      .map(type, using: decoder)
+  }
+}
+
+public extension PrimitiveSequenceType where TraitType == MaybeTrait, ElementType: Encodable {
+  public func toDictionary() -> PrimitiveSequence<TraitType, [String:Any]> {
+    return self.map { encodable -> [String: Any] in
+      let data = try JSONEncoder().encode(encodable)
+      let dictionary = try JSONSerialization.jsonObject(with: data) as? [String: Any]
+      return dictionary ?? [:]
+    }
+  }
+}
+
+public extension PrimitiveSequenceType where TraitType == MaybeTrait, ElementType: Encodable {
+  public func toJSONString(_ encoding: String.Encoding = .utf8) -> PrimitiveSequence<TraitType, String> {
+    return self.map { encodable -> String in
+      let data = try JSONEncoder().encode(encodable)
+      let json = String(data: data, encoding: encoding)
+      return json ?? "{}"
+    }
+  }
+}

Sources/RxCodable/ObservableType+RxCodable.swift

@@ -17,3 +17,31 @@ public extension ObservableType where E == String {
       .map(type, using: decoder)
   }
 }
+
+public extension ObservableType where E == [String: Any] {
+  public func map<T>(_ type: T.Type, using decoder: JSONDecoder? = nil) -> Observable<T> where T: Decodable {
+    return self
+      .map { dict in try JSONSerialization.data(withJSONObject: dict) }
+      .map(type, using: decoder)
+  }
+}
+
+public extension ObservableType where E: Encodable {
+  public func toDictionary() -> Observable<[String:Any]> {
+    return self.map { encodable -> [String: Any] in
+      let data = try JSONEncoder().encode(encodable)
+      let dictionary = try JSONSerialization.jsonObject(with: data) as? [String: Any]
+      return dictionary ?? [:]
+    }
+  }
+}
+
+public extension ObservableType where E: Encodable {
+  public func toJSONString(_ encoding: String.Encoding = .utf8) -> Observable<String> {
+    return self.map { encodable -> String in
+      let data = try JSONEncoder().encode(encodable)
+      let json = String(data: data, encoding: encoding)
+      return json ?? "{}"
+    }
+  }
+}

Sources/RxCodable/Single+RxCodable.swift

@@ -17,3 +17,31 @@ public extension PrimitiveSequenceType where TraitType == SingleTrait, ElementTy
       .map(type, using: decoder)
   }
 }
+
+public extension PrimitiveSequenceType where TraitType == SingleTrait, ElementType == [String: Any] {
+  public func map<T>(_ type: T.Type, using decoder: JSONDecoder? = nil) -> PrimitiveSequence<TraitType, T> where T: Decodable {
+    return self
+      .map { dict in try JSONSerialization.data(withJSONObject: dict) }
+      .map(type, using: decoder)
+  }
+}
+
+public extension PrimitiveSequenceType where TraitType == SingleTrait, ElementType: Encodable {
+  public func toDictionary() -> PrimitiveSequence<TraitType, [String:Any]> {
+    return self.map { encodable -> [String: Any] in
+      let data = try JSONEncoder().encode(encodable)
+      let dictionary = try JSONSerialization.jsonObject(with: data) as? [String: Any]
+      return dictionary ?? [:]
+    }
+  }
+}
+
+public extension PrimitiveSequenceType where TraitType == SingleTrait, ElementType: Encodable {
+  public func toJSONString(_ encoding: String.Encoding = .utf8) -> PrimitiveSequence<TraitType, String> {
+    return self.map { encodable -> String in
+      let data = try JSONEncoder().encode(encodable)
+      let json = String(data: data, encoding: encoding)
+      return json ?? "{}"
+    }
+  }
+}

Tests/RxCodableTests/RxCodableTests.swift

@@ -76,4 +76,58 @@ class RxCodableTests: XCTestCase {
     XCTAssertEqual(try Single.just(jsonString).map([User].self).toBlocking().first()!, users)
     XCTAssertEqual(try Maybe.just(jsonString).map([User].self).toBlocking().first()!, users)
   }
+
+  func testMapCodableFromDictionary() {
+    let dictionary:[String:Any] = [
+      "id": 123,
+      "name": "iamchiwon",
+    ]
+    let user = User(id: 123, name: "iamchiwon")
+    XCTAssertEqual(try Observable.just(dictionary).map(User.self).toBlocking().first()!, user)
+    XCTAssertEqual(try Single.just(dictionary).map(User.self).toBlocking().first()!, user)
+    XCTAssertEqual(try Maybe.just(dictionary).map(User.self).toBlocking().first()!, user)
+  }
+
+  func testMapCodableToDictionary() {
+    let dictionary:[String:Any] = [
+      "id": 123,
+      "name": "iamchiwon",
+      ]
+    let user = User(id: 123, name: "iamchiwon")
+    XCTAssertEqual(try Observable.just(user).toDictionary().toBlocking().first()! as NSObject, dictionary as NSObject)
+    XCTAssertEqual(try Single.just(user).toDictionary().toBlocking().first()! as NSObject, dictionary as NSObject)
+    XCTAssertEqual(try Maybe.just(user).toDictionary().toBlocking().first()! as NSObject, dictionary as NSObject)
+  }
+
+  func testMapCodableToJSONString() {
+    let jsonString = """
+    {
+      "id": 123,
+      "name": "iamchiwon"
+    }
+    """
+    let user = User(id: 123, name: "iamchiwon")
+    XCTAssertEqual(try Observable.just(user).toJSONString().toBlocking().first()!,
+                   try Observable.just(jsonString).map(User.self).toJSONString().toBlocking().first()!)
+    XCTAssertEqual(try Single.just(user).toJSONString().toBlocking().first()!,
+                   try Single.just(jsonString).map(User.self).toJSONString().toBlocking().first()!)
+    XCTAssertEqual(try Maybe.just(user).toJSONString().toBlocking().first()!,
+                   try Maybe.just(jsonString).map(User.self).toJSONString().toBlocking().first()!)
+  }
+
+  func testMapCodableFromJSONStringToDictionary() {
+    let jsonString = """
+    {
+      "id": 123,
+      "name": "iamchiwon"
+    }
+    """
+    let dictionary:[String:Any] = [
+      "id": 123,
+      "name": "iamchiwon",
+      ]
+    XCTAssertEqual(try Observable.just(jsonString).map(User.self).toDictionary().toBlocking().first()! as NSObject, dictionary as NSObject)
+    XCTAssertEqual(try Single.just(jsonString).map(User.self).toDictionary().toBlocking().first()! as NSObject, dictionary as NSObject)
+    XCTAssertEqual(try Maybe.just(jsonString).map(User.self).toDictionary().toBlocking().first()! as NSObject, dictionary as NSObject)
+  }
 }