The minimal expression of a Flux architecture in Swift.
Mini is built with be a first class citizen in Swift applications: macOS, iOS and tvOS applications. With Mini, you can create a thread-safe application with a predictable unidirectional data flow, focusing on what really matters: build awesome applications.
- Xcode 10 or later
- Swift 5.0 or later
- iOS 11 or later
- macOS 10.13 or later
- tvOS 11 or later
- Create a
Package.swift
file.
// swift-tools-version:5.0
import PackageDescription
let package = Package(
name: "MiniSwiftProject",
dependencies: [
.package(url: "https://github.com/bq/mini-swift.git"),
],
targets: [
.target(name: "MiniSwiftProject", dependencies: ["Mini" /*, "MiniPromises, MiniTasks"*/])
]
)
- Mini comes with a bare implementation and two external utility packages in order to ease the usage of the library named
MiniTasks
andMiniPromises
, both dependant on theMini
base or core package.
$ swift build
- Add this to you
Podfile
:
pod "Mini-Swift"
# pod "Mini-Swift/MiniPromises"
# pod "Mini-Swift/MiniTasks"
- We also offer two subpecs for logging and testing:
pod "Mini-Swift/Log"
pod "Mini-Swift/Test"
- MiniSwift is a library which aims the ease of the usage of a Flux oriented architecture for Swift applications. Due its Flux-based nature, it heavily relies on some of its concepts like Store, State, Dispatcher, Action, Task and Reducer.
-
The minimal unit of the architecture is based on the idea of the State. State is, as its name says, the representation of a part of the application in a moment of time.
-
The State is a simple
struct
which is conformed of different Promises that holds the individual pieces of information that represents the current state, this can be implemented as follows. -
For example:
// If you're using MiniPromises
struct MyCoolState: StateType {
let cool: Promise<Bool>
}
// If you're using MiniTasks
struct MyCoolState: StateType {
let cool: Bool?
let coolTask: AnyTask
}
-
The default inner state of a
Promise
isidle
. On the other hand, the default inner state of aTask
isidle
as well. This means that noAction
(see more below), has started any operation over thatPromise
orTask
. -
Both
Promise
andTask
can hold any kind of aditional properties that the developer might encounter useful for its implementation, for example, hold aDate
for cache usage:
let promise: Promise<Bool> = .idle()
promise.date = Date()
// Later on...
let date: Date = promise.date
let task: AnyTask = .idle()
task.date = Date()
// Later on...
let date: Date = task.date
-
The core idea of a
State
is its immutability, so once created, no third-party objects are able to mutate it out of the control of the architecture flow. -
As can be seen in the example, a
State
has a pair ofTask
+Result
usually (that can be any object, if any), which is related with the execution of theTask
. In the example above,CoolTask
is responsible, through itsReducer
to fulfill theAction
with theTask
result and furthermore, the newState
. -
Furthermore, the
Promise
object unifies the Status + Result tuple, so it can store both the status of an ongoing task and the associated payload produced by it.
- An
Action
is the piece of information that is being dispatched through the architecture. Anystruct
can conform to theAction
protocol, with the only requirement of being unique its name per application.
struct RequestContactsAccess: Action {
// As simple as this is.
}
-
Action
s are free of have some pieces of information attached to them, that's why Mini provides the user with two main utility protocols:CompletableAction
,EmptyAction
andKeyedPayloadAction
.- A
CompletableAction
is a specialization of theAction
protocol, which allows the user attach both aTask
and some kind of object that gets fulfilled when theTask
succeeds.
struct RequestContactsAccessResult: CompletableAction { let promise: Promise<Bool> typealias Payload = Bool }
- An
EmptyAction
is a specialization ofCompletableAction
where thePayload
is aSwift.Void
, this means it only has associated aPromise<Void>
.
struct ActivateVoucherLoaded: EmptyAction { let promise: Promise<Void> }
- A
KeyedPayloadAction
, adds aKey
(which isHashable
) to theCompletableAction
. This is a special case where the sameAction
produces results that can be grouped together, tipically, under aDictionary
(i.e., anAction
to search contacts, and grouped by their main phone number).
struct RequestContactLoadedAction: KeyedCompletableAction { typealias Payload = CNContact typealias Key = String let promise: [Key: Promise<Payload?>] }
- A
We take the advantage of using
struct
, so all initializers are automatically synthesized.
Examples are done with
Promise
, but there're equivalent to be used withTask
s.
-
A
Store
is the hub where decissions and side-efects are made through the ingoing and outgoingAction
s. AStore
is a generic class to inherit from and associate aState
for it. -
A
Store
may produceState
changes that can be observed like any other RxSwift'sObservable
. In this way aView
, or any other object of your choice, can receive newState
s produced by a certainStore
. -
A
Store
reduces the flow of a certain amount ofAction
s through thevar reducerGroup: ReducerGroup
property. -
The
Store
is implemented in a way that has two generic requirements, aState: StateType
and aStoreController: Disposable
. TheStoreController
is usually a class that contains the logic to perform theActions
that might be intercepted by the store, i.e, a group of URL requests, perform a database query, etc. -
Through generic specialization, the
reducerGroup
variable can be rewritten for each case of pairState
andStoreController
without the need of subclassing theStore
.
extension Store where State == TestState, StoreController == TestStoreController {
var reducerGroup: ReducerGroup {
return ReducerGroup(
// Using Promises
Reducer(of: OneTestAction.self, on: dispatcher) { action in
self.state = self.state.copy(testPromise: *.value(action.counter))
},
// Using Tasks
Reducer(of: OneTestAction.self, on: dispatcher) { action in
self.state = self.state.copy(data: *action.payload, dataTask: *action.task)
}
)
}
}
- In the snippet above, we have a complete example of how a
Store
would work. We use theReducerGroup
to indicate how theStore
will interceptAction
s of typeOneTestAction
and that everytime it gets intercepted, theStore
'sState
gets copied (is not black magic 🧙, is through a set of Sourcery scripts that are distributed with this package).
If you are using SPM or Carthage, they doesn't really allow to distribute assets with the library, in that regard we recommend to just install
Sourcery
in your project and use the templates that can be downloaded directly from the repository under theTemplates
directory.
- When working with
Store
instances, you may retain a strong reference of itsreducerGroup
, this is done using thesubscribe()
method, which is aDisposable
that can be used like below:
let bag = DisposeBag()
let store = Store<TestState, TestStoreController>(TestState(), dispatcher: dispatcher, storeController: TestStoreController())
store
.subscribe()
.disposed(by: bag)
- The last piece of the architecture is the
Dispatcher
. In an application scope, there should be only oneDispatcher
alive from which every action is being dispatched.
let action = TestAction()
dispatcher.dispatch(action, mode: .sync)
- With one line, we can notify every
Store
which has defined a reducer for that type ofAction
.
-
Mini is built over a request-response unidirectional flow. This is achieved using pair of
Action
, one for making the request of a change in a certainState
, and anotherAction
to mutate theState
over the result of the operation being made. -
This is much simplier to explain with a code example:
// We define our state in first place:
struct TestState: StateType {
// Our state is defined over the Promise of an Integer type.
let counter: Promise<Int>
init(counter: Promise<Int> = .idle()) {
self.counter = counter
}
public func isEqual(to other: StateType) -> Bool {
guard let state = other as? TestState else { return false }
guard counter == state.counter else { return false }
return true
}
}
// We define our actions, one of them represents the request of a change, the other one the response of that change requested.
// This is the request
struct SetCounterAction: Action {
let counter: Int
}
// This is the response
struct SetCounterActionLoaded: Action {
let counter: Int
}
// As you can see, both seems to be the same, same parameters, initializer, etc. But next, we define our StoreController.
// The StoreController define the side-effects that an Action might trigger.
class TestStoreController: Disposable {
let dispatcher: Dispatcher
init(dispatcher: Dispatcher) {
self.dispatcher = dispatcher
}
// This function dispatches (always in a async mode) the result of the operation, just giving out the number to the dispatcher.
func counter(_ number: Int) {
self.dispatcher.dispatch(SetCounterActionLoaded(counter: number), mode: .async)
}
public func dispose() {
// NO-OP
}
}
// Last, but not least, the Store definition with the Reducers
extension Store where State == TestState, StoreController == TestStoreController {
var reducerGroup: ReducerGroup {
ReducerGroup(
// We can use Promises:
// We set the state with a Promise as .pending, someone has to fill the requirement later on. This represents the Request.
Reducer(of: SetCounterAction.self, on: self.dispatcher) { action in
guard !self.state.counter.isOnProgress else { return }
self.state = TestState(counter: .pending())
self.storeController.counter(action.counter)
},
// Next we receive the Action dispatched by the StoreController with a result, we must fulfill our Promise and notify the store for the State change. This represents the Response.
Reducer(of: SetCounterActionLoaded.self, on: self.dispatcher) { action in
self.state.counter
.fulfill(action.counter)
.notify(to: self)
}
)
}
}
// We define our state in first place:
struct TestState: StateType {
// Our state is defined over the Promise of an Integer type.
let counter: Int?
let counterTask: AnyTask
init(counter: Int = nil,
counterTask: AnyTask = .idle()) {
self.counter = counter
self.counterTask = counterTask
}
public func isEqual(to other: StateType) -> Bool {
guard let state = other as? TestState else { return false }
guard counter == state.counter else { return false }
guard counterTask == state.counterTask else { return false }
return true
}
}
// We define our actions, one of them represents the request of a change, the other one the response of that change requested.
// This is the request
struct SetCounterAction: Action {
let counter: Int
}
// This is the response
struct SetCounterActionLoaded: Action {
let counter: Int
let counterTask: AnyTask
}
// As you can see, both seems to be the same, same parameters, initializer, etc. But next, we define our StoreController.
// The StoreController define the side-effects that an Action might trigger.
class TestStoreController: Disposable {
let dispatcher: Dispatcher
init(dispatcher: Dispatcher) {
self.dispatcher = dispatcher
}
// This function dispatches (always in a async mode) the result of the operation, just giving out the number to the dispatcher.
func counter(_ number: Int) {
self.dispatcher.dispatch(
SetCounterActionLoaded(counter: number,
counterTask: .success()
),
mode: .async)
}
public func dispose() {
// NO-OP
}
}
// Last, but not least, the Store definition with the Reducers
extension Store where State == TestState, StoreController == TestStoreController {
var reducerGroup: ReducerGroup {
ReducerGroup(
// We can use Tasks:
// We set the state with a Task as .running, someone has to fill the requirement later on. This represents the Request.
Reducer(of: SetCounterAction.self, on: dispatcher) { action in
guard !self.state.counterTask.isRunning else { return }
self.state = TestState(counterTask: .running())
self.storeController.counter(action.counter)
},
// Next we receive the Action dispatched by the StoreController with a result, we must fulfill our Task and update the data associated with the execution of it on the State. This represents the Response.
Reducer(of: SetCounterActionLoaded.self, on: dispatcher) { action in
guard self.state.rawCounterTask.isRunning else { return }
self.state = TestState(counter: action.counter, counterTask: action.counterTask)
}
)
}
}
All the documentation available can be found here
The work in this repository up to April 30th, 2021 was done by bq. Thanks for all the work!!
This project is licensed under the Apache Software License, Version 2.0.
Copyright 2021 HyperDevs
Copyright 2019 BQ
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.