### Request Account Data Example

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Example function to request account updates. This function will continue until the same request is made with 'false' instead of 'true'.

```clojure
(defn example-account-data-request []
  ;will keep going until you send the same request with false instead of true
  (cs/request-account-updates (:ecs connection) true account))
```

--------------------------------

### Place Order (Interop)

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Example of placing an order using interop with the IB client library.

```APIDOC
## example-sending-order-interop

### Description
Example call to place an order using interop.

### Parameters
- `order-id`: The ID for the order.
- `connection`: The connection object.
- `MSFT-contract`: Contract object.
- `safe-limit-buy-order-order`: Order object.
```

--------------------------------

### Connection Setup

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Establishes a connection to the Interactive Brokers gateway. Requires a client ID, host, port, and a message handler function.

```clojure
(def connection (gateway/connect 2 "localhost" default-port println)) ;you may need to change the port
```

--------------------------------

### SyntaxHighlighter Highlighter Initialization

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Initializes the highlighter instance. Constructor is not used for initialization to prevent execution during brush inheritance setup.

```javascript
init: function(params) {
  this.id = guid(); // register this instance in the highlighters list
  storeHighlighter(this);
  // local params take precedence over defaults
  this.params = merge(sh.defaults, params || {})
  // process light mode
  if (this.getParam('light') == true)
    this.params.toolbar = this.params.gutter = false;
}
```

--------------------------------

### Comparison Utilities in REPL

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Provides example REPL commands for comparing the old text-based EWrapper methods with the new JavaParser-based methods, and for inspecting the generated reification forms.

```clojure
(comment
  "To compare old vs new implementations in REPL:

  ; See parsed methods from JavaParser:
  (take 5 ewrapper-methods)

  ; See old text-parsed methods:
  (take 5 ewrapper-java-methods)

  ; Compare method counts:
  (count ewrapper-methods)    ; NEW JavaParser-based
  (count ewrapper-java-methods)  ; OLD text-based

  ; See generated reification forms:
  (take 10 reification)       ; OLD

```

--------------------------------

### Cancel Order Example

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Example function to cancel an order using a provided order ID.

```clojure
(defn example-order-cancel [order-id]
  ;need to submit same order-id as above
  (cs/cancel-order (:ecs connection) order-id))
```

--------------------------------

### request-real-time-bars

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Start receiving real time bar results.

```APIDOC
## request-real-time-bars

### Description
Starts receiving real-time bar data for a specified contract.

### Parameters
- **ecs**: The execution context.
- **request-id**: The unique identifier for the request.
- **contract**: The contract details.
- **what-to-show**: The type of data to show (e.g., :trades, :midpoint).
- **use-regular-trading-hours?**: Boolean indicating whether to use regular trading hours.
```

--------------------------------

### Request Historical Data (Interop)

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Example of requesting historical data using interop with the IB client library.

```APIDOC
## example-historical-request-interop

### Description
Example call to request historical data using interop.

### Parameters
- `connection`: The connection object.
- `requests`: Atom for tracking request count.
- `ESH6-contract`: Contract object.
- `"20251610 00:00:00 UTC"`: End time for the data.
- `"10 D"`: Duration.
- `"1 day"`: Bar size.
- `"TRADES"`: What to show.
- `1`: Use regular trading hours flag.
- `1`: Bar size unit.
- `1`: Unknown parameter.
- `false`: Unknown parameter.
- `nil`: Unknown parameter.
```

--------------------------------

### Request Scanner Subscription

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Starts receiving market scanner results. Requires the ECS instance, ticker ID, subscription details, and optional options.

```clojure
(defn request-scanner-subscription
  [ecs ticker-id subscription subscription-options subscription-filter-options]
  (.reqScannerSubscription ecs
                           ticker-id
                           (map-> com.ib.client.ScannerSubscription subscription)
                           subscription-options
                           subscription-filter-options))
```

--------------------------------

### XRegExp Add Token Examples

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Demonstrates how to add custom tokens to XRegExp for extended regular expression capabilities. These tokens handle specific patterns like capturing groups and conditional expressions.

```javascript
XRegExp.addToken(/\((?!\?)/,function(){this.captureNames.push(null);return"("});XRegExp.addToken(/\(\?<(\[$\w\]+)>/,function(p){this.captureNames.push(p[1]);this.hasNamedCapture=true;return"("});XRegExp.addToken(/\\k<(\[\w$]*)>/,function(q){var p=l(this.captureNames,q[1]);return p>-1?"\\"+(p+1)+(isNaN(q.input.charAt(q.index+q[0].length))?"":"(?:)"):q[0]});XRegExp.addToken(/\\\[\\^?\\]/,function(p){return p[0]==="[ ]"?"\\b\\B":"[\\s\\S]"});XRegExp.addToken(/^\(\?(\[imsx\]+)\)/,function(p){this.setFlag(p[1]);return""});XRegExp.addToken(/(?:\s+|#.*)+/,function(p){return m.test.call(n,p.input.slice(p.index+p[0].length))?"":"(?:)"},XRegExp.OUTSIDE_CLASS,function(){return this.hasFlag("x")});XRegExp.addToken(/\./,function(){return"[\\s\\S]"},XRegExp.OUTSIDE_CLASS,function(){return this.hasFlag("s")})
```

--------------------------------

### request-scanner-subscription

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Call this method to start receiving market scanner results through the scannerData() EWrapper method.

```APIDOC
## request-scanner-subscription

### Description
Starts receiving market scanner results.

### Parameters
- **ecs**: The execution context.
- **ticker-id**: The ticker ID for the subscription.
- **subscription**: The scanner subscription details.
- **subscription-options**: Additional subscription options.
- **subscription-filter-options**: Filter options for the subscription.
```

--------------------------------

### Request Real Time Bars

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Starts receiving real-time bar results. Requires ECS, contract details, and display options. The `5` parameter is currently ignored.

```clojure
(defn request-real-time-bars
  [ecs request-id contract what-to-show use-regular-trading-hours?]
  (.reqRealTimeBars ecs request-id
                    (map-> com.ib.client.Contract contract)
                    5                                ; currently being ignored
                    (.name (translate :to-ib :what-to-show what-to-show))
                    use-regular-trading-hours?
                    nil))
```

--------------------------------

### Get Market Snapshot

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Returns a snapshot of the market for the specified contract. Handles data, errors, and end events to populate the result.

```clojure
(defn market-snapshot
  [connection contract]
  (let [result (promise)
        data (atom nil)
        handlers {:data (fn [{:keys [field value]}] (swap! data assoc field value))
                  :error #(reset! data %)
                  :end #(deliver result @data)}]
    (g/request-market-data connection contract nil true handlers)
    @result))
```

--------------------------------

### Connect to IB Gateway or TWS

Source: https://context7.com/alex314159/ib-re-actor-976-plus/llms.txt

Opens a socket connection, starts the message-processing thread, and returns connection details. An optional listener function can receive all callback messages.

```clojure
(require '[ib-re-actor-976-plus.gateway :as gateway])

;; Connect to live TWS (port 7496) or paper (port 7497)
(def conn (gateway/connect 1 "localhost" 7497 println))
;; => {:ecs #object[EClientSocket], :subscribers #atom[...], :next-id #atom[1]}

;; Check connection state
(gateway/is-connected? conn)  ;; => true

;; Disconnect cleanly (does NOT cancel live orders)
(gateway/disconnect conn)
```

--------------------------------

### gateway/connect

Source: https://context7.com/alex314159/ib-re-actor-976-plus/llms.txt

Opens a socket connection to IB Gateway or TWS, starts the EReader message-processing thread, and returns a connection map. An optional initial listener function receives every callback message as a Clojure map.

```APIDOC
## gateway/connect — Connect to IB Gateway or TWS

### Description
Opens a socket connection to IB Gateway or TWS, starts the `EReader` message-processing thread, and returns a connection map containing `:ecs` (the underlying `EClientSocket`), `:subscribers` (an atom of listener functions), and `:next-id` (an auto-incrementing request/order ID atom). An optional initial listener function receives every callback message as a Clojure map.

### Usage
```clojure
(require '[ib-re-actor-976-plus.gateway :as gateway])

;; Connect to live TWS (port 7496) or paper (port 7497)
(def conn (gateway/connect 1 "localhost" 7497 println))
;; => {:ecs #object[EClientSocket], :subscribers #atom[...], :next-id #atom[1]}

;; Check connection state
(gateway/is-connected? conn)  ;; => true

;; Disconnect cleanly (does NOT cancel live orders)
(gateway/disconnect conn)
```
```

--------------------------------

### Function Utilities: guid, proxy, access

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Includes functions for managing unique IDs, creating function proxies with context and arguments, and accessing or setting properties on elements.

```javascript
guid:1,proxy:function(a,c){if(typeof c=="string"){var d=a[c];c=a,a=d}if(!e.isFunction(a))return b;var f=F.call(arguments,2),g=function(){return a.apply(c,f.concat(F.call(arguments)))};g.guid=a.guid=a.guid||g.guid||e.guid++;return g}
```

```javascript
access:function(a,c,d,f,g,h){var i=a.length;if(typeof c=="object"){for(var j in c)e.access(a,j,c[j],f,g,d);return a}if(d!==b){f=!h&&f&&e.isFunction(d);for(var k=0;k<i;k++)g(a[k],c,f?d.call(a[k],k,g(a[k],c)):d,h);return a}return i?g(a[0],c):b}
```

--------------------------------

### Connect to IB Gateway/TWS

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Establishes a connection to the IB Gateway or TWS. This function must be called before any other client operations. It starts a background thread for message processing.

```clojure
(defn connect
  ([wr signal host port client-id]
   (let [ecs (EClientSocket. wr signal)]
     (.eConnect ecs host port client-id)
     (let [reader (EReader. ecs signal)]
       (.start reader)
       (.start (Thread. ^Runnable (fn [] (-process-messages ecs reader signal)))) ;we're not using a future as somehow they fail silently with
       ;java.lang.AbstractMethodError: Receiver class clibtrader.ib_re_actor.wrapper$create$reify__7992 does not define or inherit an implementation of the resolved method 'abstract void tickReqParams(int, double, java.lang.String, int)' of interface com.ib.client.EWrapper.
       ;seems somewhat linked to https://github.com/clojure-emacs/cider/issues/1404
       ecs))))
```

--------------------------------

### Request Contract Details

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Gets details for a specified contract. Returns a list of contract details. A non-ambiguous contract yields a single item.

```clojure
(defn contract-details
  [connection contract]
  (let [result (promise)]
    (g/request-contract-details connection contract
                                (conjing-handlers result))
    @result))
```

--------------------------------

### Multimethod Listener for IB ReActor 976 Plus

Source: https://context7.com/alex314159/ib-re-actor-976-plus/llms.txt

Defines a multimethod listener that dispatches based on the `:type` key in incoming messages. This setup is suitable for managing per-account state and handling various event types asynchronously.

```clojure
(require '[ib-re-actor-976-plus.gateway :as gateway])
(require '[ib-re-actor-976-plus.mapping :refer [->map]])
(require '[ib-re-actor-976-plus.translation :as t])
(require '[clojure.tools.logging :as log])

(def state (atom {}))

(defmulti listener (fn [account msg] (:type msg)))

(defmethod listener :next-valid-id [account msg]
  (swap! state assoc-in [:order-ids account] (:order-id msg)))

(defmethod listener :update-account-value [account msg]
  (let [{:keys [key value currency]} msg
        avk (t/translate :from-ib :account-value-key key)
        val (cond
              (t/numeric-account-value?  avk) (parse-double value)
              (t/integer-account-value? avk) (parse-long value)
              (t/boolean-account-value? avk) (parse-boolean value)
              :else value)]
    (swap! state assoc-in [:account-data account avk] val)))

(defmethod listener :historical-data [account msg]
  (let [{:keys [req-id bar]} msg
        {:keys [time open high low close volume]} (->map bar)]
    (swap! state update-in [:bars req-id] conj [time open high low close volume])))

(defmethod listener :error [account msg]
  (let [{:keys [id code message]} msg]
    (if (#{2104 2106 2158} code)
      (log/trace account code message)
      (log/warn  account id code message))))

(defmethod listener :default [account msg]
  (log/info (name account) msg))
```

```clojure
;; Connect multiple accounts
(def accounts {:U1234567 {:client-id 1 :port 7496}
               :U9876543 {:client-id 2 :port 7490}})

(doseq [[acct {:keys [client-id port]}] accounts]
  (swap! state assoc-in [:connections acct]
         (gateway/connect client-id "localhost" port
                          (fn [msg] (listener acct msg)))))

```

--------------------------------

### Request Account Updates

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Starts receiving account values, portfolio, and last update time. The subscribe? flag determines whether to subscribe or unsubscribe. account-code specifies the account to query.

```clojure
(defn request-account-updates
  [ecs subscribe? account-code]
  (.reqAccountUpdates ecs subscribe? account-code))
```

--------------------------------

### Request Account Updates

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Call this function to start getting account values, portfolio, and last update time information. The account data will be fed back through the updateAccountTime(), updateAccountValue() and updatePortfolio() EWrapper methods.

```APIDOC
## request-account-updates

### Description
Starts receiving account values, portfolio, and last update time information.

### Method
(defn request-account-updates [ecs subscribe? account-code])
```

--------------------------------

### Request News Bulletins

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Starts receiving news bulletins. Each bulletin is sent as a :news-bulletin, :exchange-unavailable, or :exchange-available message. Set all-messages? to true to receive all bulletins.

```clojure
(defn request-news-bulletins
  (\[ecs all-messages?]
   (.reqNewsBulletins ecs all-messages?)))
```

--------------------------------

### Get Element Height

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Gets the height of an element, including padding. If no argument is provided, it returns the current height.

```javascript
f.fn["inner"+c]=function(){var a=this[0];return a?a.style?parseFloat(f.css(a,d,"padding")):this[d]():null}
```

--------------------------------

### Get Outer Element Height

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Gets the height of an element, including padding and border. Optionally includes margin if specified.

```javascript
f.fn["outer"+c]=function(a){var b=this[0];return b?b.style?parseFloat(f.css(b,d,a?"margin":"border")):this[d]():null}
```

--------------------------------

### Find Index in Array

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Finds the index of an element in an array, starting from a specified index. Ensures the starting index is non-negative.

```javascript
function indexOf(array, searchElement, fromIndex) { fromIndex = Math.max(fromIndex || 0, 0); for (var i = fromIndex; i < array.length; i++) if(array[i] == searchElement) return i; return -1; }
```

--------------------------------

### Connect to IB Gateway/TWS (Simple)

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Establishes a simple connection to the IB Gateway or TWS, accepting only one listener function set at creation. Returns an immutable connection object.

```clojure
(defn connect-simple
  ([client-id]
   (connect-simple client-id "localhost" default-paper-port println))
  ([client-id host port listener-function]
   (try
     (let [wr (wrapper/create (fn [message] (try (listener-function message) (catch Throwable t (log/error t "Error dispatching" message)))))
           signal (EJavaSignal.)
           ecs (cs/connect wr signal host port client-id)]
       (when-not (= :error default-server-log-level)
         (cs/set-server-log-level ecs default-server-log-level))
       {:ecs ecs})
     (catch Exception ex
       (log/error "Error trying to connect to " host ":" port ": " ex)))))
```

--------------------------------

### Create EWrapper Wrapper

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Demonstrates creating a wrapper for the EWrapper interface using both old and new methods. This is useful for testing wrapper creation.

```clojure
(take 10 reification-new)   ; NEW

  ; Test creating wrapper (both should work):
  (def test-cb (fn [msg] (println \"Got:\
```

--------------------------------

### jQuery CSS: Get Element Dimensions

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Retrieves the computed width or height of an element. This function is used internally to get accurate dimensions, considering various box models.

```javascript
function bC(a,b,c){var d=b==="width"?a.offsetWidth:a.offsetHeight,e=b==="width"?bx:by,g=0,h=e.l
```

--------------------------------

### Main Function Entry Point

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

The main entry point for the application. Currently, it prints the detected TWS API version.

```clojure
(defn -main
  [& args]
  (println "Detected TWS API version" translation/tws-version))
```

--------------------------------

### Syntax Highlighter Initialization

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Initializes the SyntaxHighlighter with optional parameters and highlights code elements. It handles brush selection and applies parameters like title and brush name.

```javascript
sh.highlight = function(params) {
  params = params || {};
  var tags = document.getElementsByTagName('script');
  for (var i = 0; i < tags.length; i++) {
    var target = tags[i];
    if (!/syntaxhighlighter/.test(target.className)) continue;
    var brushName = target.className.match(/brush: (\w+)/); 
    if (!brushName) continue;
    brushName = brushName[1];
    var propertyName = 'innerHTML';
    var highlighter = null;
    if (target.justContent) propertyName = 'justContent';
    var code = target[propertyName];
    if (code == null || code == '') {
      code = target.text; // IE 
      if (code == null) continue;
    }
    var highlighter = null;
    if (brushName) {
      var brush = findBrush(brushName);
      if (brush) highlighter = new brush();
      else continue;
    } else {
      highlighter = new SyntaxHighlighter();
    }
    code = target[propertyName]; // remove CDATA from <SCRIPT/> tags if it's present
    if (conf.useScriptTags) code = stripCData(code);
    // Inject title if the attribute is present
    if ((target.title || '') != '') params.title = target.title;
    params['brush'] = brushName;
    highlighter.init(params);
    element = highlighter.getDiv(code);
    // carry over ID if ((target.id || '') != '') element.id = target.id;
    target.parentNode.replaceChild(element, target);
  }
}
```

--------------------------------

### Connection Time

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Get the time when the API application connected to TWS.

```APIDOC
## connection-time

### Description
Returns the time the API application made a connection to TWS.

### Method
(defn connection-time
  [ecs])
```

--------------------------------

### Get Connection Time

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Returns the time the API application made a connection to TWS.

```clojure
(defn connection-time
  [ecs]
  ;(translate :from-ib :connection-time (.getTwsConnectionTime ecs)))
  (.getTwsConnectionTime ecs))
```

--------------------------------

### Place Order (Java Interop)

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Places a trade order using Java interoperability. Requires the IB client object, an order ID, contract object, and order object.

```clojure
(defn example-sending-order-interop [order-id]
  ;the next available order-id would have been printed at connection
  (.placeOrder (:ecs connection) order-id MSFT-contract safe-limit-buy-order-order))
```

--------------------------------

### Connect to IB Gateway/TWS (Synchronous)

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Establishes a connection to the IB Gateway or TWS. Requires a client-id and optionally accepts host, port, and a listener function. Handles connection errors.

```clojure
(defn connect
  ([client-id]
   (connect client-id "localhost" default-paper-port println))
  ([client-id host port listener-function] ;ADD ONE VARIABLE
   (let [subscribers (atom {listener-function listener-function})]
     (try
       (let [wr (wrapper/create (message-dispatcher subscribers))
             signal (EJavaSignal.)
             ecs (cs/connect wr signal host port client-id)]
         (when-not (= :error default-server-log-level)
           (cs/set-server-log-level ecs default-server-log-level))
         {:ecs         ecs
          :subscribers subscribers
          })
       (catch Exception ex
         (log/error "Error trying to connect to " host ":" port ": " ex))))))
```

--------------------------------

### Get Server Version

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Returns the version of the TWS instance to which the API application is connected.

```clojure
(defn server-version
  [ecs]
  (.serverVersion ecs))
```

--------------------------------

### Place Order (Clojure API)

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Places a trade order using the client-socket API. Requires the IB client object, an order ID, contract details, and order details.

```clojure
(defn example-sending-order [order-id]
  ;the next available order-id would have been printed at connection
  (cs/place-order (:ecs connection) order-id MSFT-map safe-limit-buy-order-map))
```

--------------------------------

### Get Stack Trace

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Helper function to capture the stack trace of an exception as a string.

```clojure
(defn- get-stack-trace [ex]
  (let [sw (StringWriter.)
        pw (PrintWriter. sw)]
    (.printStackTrace ex pw)
    (.toString sw)))
```

--------------------------------

### request-historical-data

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Start receiving historical price bars stretching back for the specified contract.

```APIDOC
## request-historical-data

### Description
Retrieves historical price bars for a specified contract.

### Parameters
- **ecs**: The execution context.
- **request-id**: The unique identifier for the request.
- **contract**: The contract details.
- **end**: The end date and time (yyyyMMdd HH:mm:ss {TMZ}).
- **duration**: The duration of the historical data.
- **duration-unit**: The unit for the duration (e.g., :second, :day, :week, :year).
- **bar-size**: The size of each bar.
- **bar-size-unit**: The unit for the bar size (e.g., :second, :minute, :hour, :day).
- **what-to-show**: The type of data to show (e.g., :trades, :midpoint, :bid, :ask).
- **use-regular-trading-hours?**: Boolean indicating whether to use regular trading hours.
- **format-date**: Integer to format the date (1 for yyyyMMdd HH:mm:ss, 2 for system time in seconds).
- **keep-up-to-date?**: Boolean to receive continuous updates.
```

--------------------------------

### Check if Date String is Finished

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Determines if a given date string starts with 'finished'.

```clojure
(defn- is-finish? [date-string]
  (.startsWith date-string "finished"))
```

--------------------------------

### gateway/connect-simple

Source: https://context7.com/alex314159/ib-re-actor-976-plus/llms.txt

Creates a connection with a single, immutable listener set at creation time. Suited to multimethod-based architectures where all event types are handled in one function. Does not include the `:next-id` atom.

```APIDOC
## gateway/connect-simple — Single-listener immutable connection

### Description
Creates a connection with a single, immutable listener set at creation time. Suited to multimethod-based architectures where all event types are handled in one function. Does **not** include the `:next-id` atom, so it cannot be used with gateway functions that auto-generate IDs.

### Usage
```clojure
(defmulti handle-event (fn [msg] (:type msg)))
(defmethod handle-event :next-valid-id [msg] (println "First order id:" (:order-id msg)))
(defmethod handle-event :error         [msg] (println "IB error:" msg))
(defmethod handle-event :default       [msg] nil)

(def conn (gateway/connect-simple 2 "localhost" 7497 handle-event))
;; => {:ecs #object[EClientSocket]}
```
```

--------------------------------

### Listener Implementation: Account Download End

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Handles the ':account-download-end' message type by logging a trace message indicating that account data has been updated.

```clojure
(defmethod listener :account-download-end [account message]
  (log/trace "Account data updated for " account))
```

--------------------------------

### Get Server Time

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Returns the server time. Uses single-value handlers to deliver the result.

```clojure
(defn server-time
  [connection]
  (let [result (promise)]
    (g/request-current-time connection
                            (single-value-handlers result))
    @result))
```

--------------------------------

### Place and Monitor Order

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Places an order and monitors its status. Requires a connection, contract, order details, and a handler for results.

```clojure
(let [result (promise)]
    (g/place-and-monitor-order connection contract order
                               (resetting-handlers result))
    @result)
```

--------------------------------

### Connect All Accounts

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Iterates through a predefined list of accounts and connects to each one using the `connect-account!` function. It also logs the next valid order IDs obtained during the connection process.

```clojure
(defn connect-all []
  (doseq [account accounts]
    (connect-account! account))
  (log/info "Next valid order-ids" (:order-ids @IB-state)))
```

--------------------------------

### Place and Monitor Order

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Places an order and sets up a handler to monitor its status. Returns the order-id, which can be used for cancellation or modification. Ensure connection and handlers are correctly configured.

```clojure
(defn place-and-monitor-order
  [connection contract order]
  (let [order-id (next-id connection)]
    (subscribe! connection order-id
                (order-monitor-handler connection order-id handlers))
    (cs/place-order (:ecs connection)
                    order-id contract (assoc order :order-id order-id))
    order-id))

```

--------------------------------

### Contract Details

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Gets details for a specified contract. Returns a list of contract details matching the description.

```APIDOC
## contract-details

### Description
Gets details for the specified contract. Will return a list of contract details matching the contract description. A non-ambiguous contract will yield a list of one item.

### Parameters
- `connection`: The connection object to the IB gateway.
- `contract`: The contract to get details for.
```

--------------------------------

### Request News Bulletins

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Starts receiving news bulletins. Each bulletin will be sent in a :news-bulletin, :exchange-unavailable, or :exchange-available message.

```APIDOC
## request-news-bulletins

### Description
Starts receiving news bulletins. Each bulletin will be sent in a :news-bulletin, :exchange-unavailable, or :exchange-available message.

### Function Signature
(request-news-bulletins [ecs all-messages?])

### Parameters
- **ecs**: The IB client object.
- **all-messages?**: Boolean indicating whether to receive all messages.
```

--------------------------------

### Define Accounts and Static Data

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Defines a list of accounts and a map of static portfolio data, including client IDs and ports, for each account.

```clojure
(def accounts ["U1234567" "U9876543"])
(def portfolio-static
  {:U1234567 {:clientId           1
              :port               7496}
   :U9876543 {:clientId           1
              :port               7490}})
```

--------------------------------

### Scroll Element Vertically

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Gets or sets the vertical scroll position of elements. For windows, it uses pageYOffset or documentElement properties.

```javascript
f.each(["Left","Top"],function(a,c){var d="scroll"+c;f.fn[d]=function(c){var e,g;if(c===b){e=this[0];if(!e)return null;g=cy(e);return g?"pageXOffset"in g?g[a?"pageYOffset":"pageXOffset"]:f.support.boxModel&&g.document.documentElement[d]||g.document.body[d]:e[d]}return this.each(function(){g=cy(this),g?g.scrollTo(a?f(g).scrollLeft():c,a?c:f(g).scrollTop()):this[d]=c})}})
```

--------------------------------

### Get Offset Parent

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Finds the closest positioned ancestor element. Returns the document body if no positioned ancestor is found.

```javascript
f.fn.extend({offsetParent:function(){return this.map(function(){var a=this.offsetParent||c.body;while(a&&!cx.test(a.nodeName)&&f.css(a,"position")==="static")a=a.offsetParent;return a})}})
```

--------------------------------

### Place Order

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Places an order using the provided connection and order details. Requires an existing connection and order ID.

```clojure
(cs/place-order (:ecs connection)
                  order-id contract (assoc order :order-id order-id))
  order-id)
```

--------------------------------

### Highlighter create Method

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

A shortcut for document.createElement(). Used to create HTML elements like DIV or A.

```javascript
create: function(name) { return document.createElement(name); }
```

--------------------------------

### Get Element Position

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Calculates the position of an element relative to its offset parent. Accounts for margins and borders of the offset parent.

```javascript
f.fn.extend({position:function(){if(!this[0])return null;var a=this[0],b=this.offsetParent(),c=this.offset(),d=cx.test(b[0].nodeName)?{top:0,left:0}:b.offset();c.top-=parseFloat(f.css(a,"marginTop"))||0,c.left-=parseFloat(f.css(a,"marginLeft"))||0,d.top+=parseFloat(f.css(b[0],"borderTopWidth"))||0,d.left+=parseFloat(f.css(b[0],"borderLeftWidth"))||0;return{top:c.top-d.top,left:c.left-d.left}}})
```

--------------------------------

### Convert to Joda Interval

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Converts a start and end time string into a Joda time interval, adjusting for day rollovers.

```clojure
(defn- joda-interval [tz [start end]]
  (let [start-dt (to-utc tz (tf/parse (tf/formatter "yyyyMMddHHmm") start))
        end-dt (to-utc tz (tf/parse (tf/formatter "yyyyMMddHHmm") end))
        mod-start (if (time/after? start-dt end-dt)
                    (time/minus start-dt (time/days 1))
                    start-dt)]
    (time/interval mod-start end-dt)))
```

--------------------------------

### Listener Implementation: Execution Details

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Handles the ':exec-details' message type by logging trace information about the account, type, request ID, contract, and execution.

```clojure
(defmethod listener :exec-details [account message]
  (let [{:keys [type req-id contract execution]} message]
    (log/trace account type req-id (map-> contract) (map-> execution))))
```

--------------------------------

### Place Order

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Places an order with the TWS. Requires connection, order ID, contract details, and order details.

```clojure
(defn place-order
  [ecs order-id contract order]
  (.placeOrder ecs order-id
               (map-> com.ib.client.Contract contract)
               (map-> com.ib.client.Order order)))
```

--------------------------------

### Listener Implementation: Open Order

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Handles the ':open-order' message type by logging trace information about the account, order type, ID, contract, order, and order state.

```clojure
(defmethod listener :open-order [account message]
  (let [{:keys [type order-id contract order order-state]} message]
    (log/trace account type order-id (map-> contract) (map-> order) (map-> order-state))))
```

--------------------------------

### Request Historical Data (Client Socket)

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Requests historical data using the client socket interface. This is an example of how to call the function.

```APIDOC
## example-historical-request

### Description
Example call to request historical data using the client socket.

### Parameters
- `connection`: The connection object.
- `requests`: Atom for tracking request count.
- `ESH6-map`: Contract details in map format.
- `"20251610 00:00:00 UTC"`: End time for the data.
- `10`: Duration.
- `:days`: Duration unit.
- `1`: Bar size.
- `:day`: Bar size unit.
- `:trades`: What to show.
- `true`: Use regular trading hours.
```

--------------------------------

### Historical Data

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Gets historical price bars for a contract. Supports various parameters to define the historical data range and granularity.

```APIDOC
## historical-data

### Description
Gets historical price bars for a contract.

### Parameters
- `connection`: The connection object to the IB gateway.
- `contract`: The contract for which to retrieve historical data.
- `end-time`: The end time for the historical data query.
- `duration`: The duration of the historical data.
- `duration-unit`: The unit for the duration (e.g., :days).
- `bar-size`: The size of each bar.
- `bar-size-unit`: The unit for the bar size.
- `what-to-show`: What data to show (e.g., :trades).
- `use-regular-trading-hours?`: Boolean indicating whether to use regular trading hours.

### Overloads
- `historical-data(connection, contract, end-time, duration, duration-unit, bar-size, bar-size-unit, what-to-show, use-regular-trading-hours?)`
- `historical-data(connection, contract, end, duration, duration-unit, bar-size, bar-size-unit)` - Defaults to `:trades true`.
```

--------------------------------

### Request Historical Data (Overloaded)

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Gets historical price bars for a contract. This is an overloaded function with different parameter sets for flexibility.

```clojure
(defn historical-data
  ("Overload 1: Full parameters"
   [connection contract end-time duration duration-unit bar-size bar-size-unit
    what-to-show use-regular-trading-hours?]
    (let [result (promise)]
      (g/request-historical-data connection contract end-time
                                duration duration-unit bar-size bar-size-unit
                                what-to-show use-regular-trading-hours?
                                (conjing-handlers result))
      @result))
  ("Overload 2: Simplified parameters, defaults to trades"
   [connection contract end
    duration duration-unit bar-size bar-size-unit]
   (historical-data connection contract end duration duration-unit
                    bar-size bar-size-unit :trades true)))
```

--------------------------------

### Connect to an IB Account

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Establishes a connection to a specified Interactive Brokers account using provided client ID, host, and port. It configures a listener for incoming messages.

```clojure
(defn connect-account! [account]
  "could replace localhost by 127.0.0.1"
  (swap! IB-state assoc-in
         [:connections account]
         (gateway/connect
           (get-in portfolio-static [account :clientId]);adding one to clientId at this point
           "localhost"
           (get-in portfolio-static [account :port])
           (fn [message] (listener account message))))
  (Thread/sleep 1000)
  (log/info "Connected account " account))
```

--------------------------------

### Syntax Highlighter - Highlight All

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Attaches an event listener to the window's load event to trigger the highlighting of all elements on the page.

```javascript
all: function(params) {
  attachEvent( window, 'load', function() {
    sh.highlight(params);
  } );
}
```

--------------------------------

### jQuery nextUntil() Method

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Gets all sibling elements after the current element until the element matched by the selector. Returns a new jQuery object.

```javascript
nextUntil:function(a,b,c){return f.dir(a,"nextSib
```

--------------------------------

### Request Market Data (Streaming)

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Initiates a request for streaming market data for a given contract. Requires the IB client object and contract information.

```clojure
(defn example-streaming-data-request []
  (cs/request-market-data
    (:ecs connection)
    (swap! requests inc)
    ESH6-map
    nil
    false
    false))
```

--------------------------------

### jQuery prevAll() Method

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Gets all sibling elements before the current element that match the selector, if provided. Returns a new jQuery object.

```javascript
prevAll:function(a){return f.dir(a,"previousSibling")}
```

--------------------------------

### Synchronous API Wrappers for REPL Use

Source: https://context7.com/alex314159/ib-re-actor-976-plus/llms.txt

Use the synchronous API wrappers for blocking calls in interactive REPL sessions. All functions require a connection established with `gateway/connect`, not `connect-simple`.

```clojure
(require '[ib-re-actor-976-plus.gateway :as g])
(require '[ib-re-actor-976-plus.synchronous :as sync])

(def conn (g/connect 1 "localhost" 7497))

;; Server time
(sync/server-time conn)
;; => {:type :current-time, :time 1746441600}

;; Account positions
(sync/positions conn)
;; => [{:type :position, :account "U1234567", :contract #object[Contract],
;;      :pos 10.0, :avg-cost 150.25} ...]

;; Contract details
(sync/contract-details conn {:symbol "AAPL" :sec-type "STK"
                              :exchange "SMART" :currency "USD"})
;; => [{:type :contract-details, :req-id 2,
;;      :contract-details #object[ContractDetails]} ...]

;; Historical data (blocks until all bars arrive)
(sync/historical-data conn
  {:symbol "MSFT" :sec-type "STK" :exchange "SMART" :currency "USD"}
  "20260506 00:00:00 US/Central"
  5 :days  1 :day  :trades true)
;; => [{:type :price-bar, :req-id 3, :bar #object[Bar]} ...]

;; Scanner
(sync/scanner-subscription conn
  {:instrument "STK" :location-code "STK.US.MAJOR"
   :scan-code "TOP_PERC_GAIN" :number-of-rows 10})

;; Execute an order synchronously (blocks until filled or cancelled)
(sync/execute-order conn
  {:symbol "MSFT" :sec-type "STK" :exchange "SMART" :currency "USD"}
  {:action :buy :total-quantity 1 :order-type :limit :lmt-price 1.0})

(g/disconnect conn)
```

--------------------------------

### jQuery nextAll() Method

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Gets all sibling elements after the current element that match the selector, if provided. Returns a new jQuery object.

```javascript
nextAll:function(a){return f.dir(a,"nextSibling")}
```

--------------------------------

### jQuery prev() Method

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Gets the immediately preceding sibling of each element in the set of matched elements. Returns a new jQuery object.

```javascript
prev:function(a){return f.nth(a,2,"previousSibling")}
```

--------------------------------

### Place and Monitor Orders with IB Re-Actor

Source: https://context7.com/alex314159/ib-re-actor-976-plus/llms.txt

Places an order and monitors its status until filled or cancelled. Auto-assigns an order ID. Use the returned order ID to cancel a specific order or call cancel-all-orders to cancel all open orders.

```clojure
(def conn (gateway/connect 1 "localhost" 7497))

(def msft {:symbol "MSFT" :sec-type "STK" :currency "USD"
           :exchange "SMART" :primary-exch "NASDAQ"})

;; Safe limit buy well below the market so it won't fill in testing
(def order {:action :buy :total-quantity 1 :order-type :limit :lmt-price 1.00})

(def order-id
  (gateway/place-and-monitor-order
    conn msft order
    {:data  (fn [status] (println "Order status:" (:status status)))
     :end   (fn []       (println "Order terminal (filled or cancelled)"))
     :error (fn [msg]    (println "Order error:" msg))}))

;; Cancel before fill
(gateway/cancel-order conn order-id)

;; Cancel ALL open orders including TWS-originated ones
(gateway/cancel-all-orders conn)
```

--------------------------------

### jQuery next() Method

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Gets the immediately following sibling of each element in the set of matched elements. Returns a new jQuery object.

```javascript
next:function(a){return f.nth(a,2,"nextSibling")}
```

--------------------------------

### Get All Elements

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Retrieves all elements within a given element. It supports different methods for element selection based on browser capabilities.

```javascript
function bl(a){return typeof a.getElementsByTagName!="undefined"?a.getElementsByTagName(""):typeof a.querySelectorAll!="undefined"?a.querySelectorAll(""):[]}
```

--------------------------------

### Store Highlighter Instance

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Stores a highlighter instance in a global collection, making it retrievable by its ID using `getHighlighterById`.

```javascript
function storeHighlighter(highlighter) {
  sh.vars.highlighters[getHighlighterId(highlighter.id)] = highlighter;
};
```

--------------------------------

### Get Element Dimensions

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Calculates the width of an element, considering padding, border, and margin. Use when precise element dimensions are needed.

```javascript
function bz(a,b,c){var d=parseFloat(b),e=["Top","Bottom","Left","Right"],g=this,h=a.style,f=a.currentStyle,i=b==="width"&&d;if(c)for(var j=0,k=e.length;j<k;j++){var l=e[j];if(f)d-=parseFloat(f["border"+l+"Width"])!!0,f["padding"+l]&&(d-=parseFloat(f["padding"+l])!!0);else if(h["border"+l+"Width"]&&(h["border"+l+"Width"].getComputedStyle||h["border"+l+"Width"]!=="medium"))d-=parseFloat(h["border"+l+"Width"])!!0,h["padding"+l]&&(d-=parseFloat(h["padding"+l])!!0);return d+"px"}d=d||(f?parseFloat(f[b]):parseFloat(h[b]))||0;if(f){d=d+("padding"===b?0:parseFloat(f["padding"+e[0]])!!0);if(b!=="padding"||b!=="border")d+=parseFloat(f["border"+e[0]+"Width"])!!0,d+=parseFloat(f["border"+e[1]+"Width"])!!0,d+=parseFloat(f["border"+e[2]+"Width"])!!0,d+=parseFloat(f["border"+e[3]+"Width"])!!0;if(b==="margin"||b==="border")d+=parseFloat(f["margin"+e[0]])!!0,d+=parseFloat(f["margin"+e[1]])!!0,d+=parseFloat(f["margin"+e[2]])!!0,d+=parseFloat(f["margin"+e[3]])!!0}else if(h){d=d+("padding"===b?0:parseFloat(h["border"+e[0]+"Width"]))!!0;if(b!=="padding"||b!=="border")d+=parseFloat(h["border"+e[0]+"Width"])!!0,d+=parseFloat(h["border"+e[1]+"Width"])!!0,d+=parseFloat(h["border"+e[2]+"Width"])!!0,d+=parseFloat(h["border"+e[3]+"Width"])!!0;if(b==="margin"||b==="border")d+=parseFloat(h["margin"+e[0]])!!0,d+=parseFloat(h["margin"+e[1]])!!0,d+=parseFloat(h["margin"+e[2]])!!0,d+=parseFloat(h["margin"+e[3]])!!0}return d+"px"}
```

--------------------------------

### place-and-monitor-order

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Places an order and monitors its status, forwarding updates to handlers.

```APIDOC
## place-and-monitor-order

### Description
Places an order and sets up a handler to monitor its status. It forwards order status updates to the `:data` handler and calls the `:end` handler when the order is filled or canceled. Returns the order ID for cancellation or modification.

### Function Signature
```clojure
(place-and-monitor-order connection contract order handlers)
```

### Parameters
- **connection**: The connection object.
- **contract**: The contract for the order.
- **order**: The order details, including order type, quantity, and price.
- **handlers**: A map containing handler functions for data, end, and error events.

### Returns
- **order-id** (string): The ID of the placed order, used for cancellation or modification.
```

--------------------------------

### Place Order

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Place a new order with the specified contract and order details.

```APIDOC
## place-order

### Description
Place a new order.

### Parameters
#### Path Parameters
*   **ecs** - The connection to use to make the request.
*   **order-id** (number) - The unique identifier for the order.
*   **contract** - The contract details for the order.
*   **order** - The order details, including action, quantity, order type, etc.

### Method
(defn place-order
  [ecs order-id contract order])
```

--------------------------------

### Script AJAX Prefilter

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

This prefilter modifies AJAX settings for script requests, disabling caching and setting the type to GET for cross-domain requests.

```javascript
f.ajaxPrefilter("script",function(a){a.cache===b&&(a.cache=!1),a.crossDomain&&(a.type="GET",a.global=!1)})
```

--------------------------------

### Namespace Declaration and Imports

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Declares the namespace for demo applications and imports necessary libraries for IB connection and data handling.

```clojure
(ns demoapps.basic-app
  (:require [ib-re-actor-976-plus.gateway :as gateway]
            [ib-re-actor-976-plus.mapping :refer [map->]]
            [ib-re-actor-976-plus.client-socket :as cs])
  (:import (com.ib.client Contract Order)))
```

--------------------------------

### Generating All Mappings for Analysis

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/MAPPING_GENERATOR.md

Use this function to generate all mappings and get a count of the generated mappings. Useful for checking the generator's output.

```clojure
(count (gen/generate-all-mappings))
```

--------------------------------

### Highlighter figureOutLineNumbers Method

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

Generates an array of line numbers starting from a specified 'first-line' parameter. It iterates through each line of the code to determine the numbers.

```javascript
figureOutLineNumbers: function(code) { var lines = [], firstLine = parseInt(this.getParam('first-line')) ; eachLine(code, function(line, index) { lines.push(index + firstLine); }); return lines; }
```

--------------------------------

### Highlighter Class Initialization

Source: https://github.com/alex314159/ib-re-actor-976-plus/blob/master/docs/uberdoc.html

The main Highlighter class is defined using prototype inheritance, with no initial code in the constructor.

```javascript
sh.Highlighter = function() { // not putting any code in here because of the prototype inheritance };
```