package com.mycompany.myapp;
// ... redacted imports ...
import com.xataface.query.XFClient;
import com.xataface.query.XFQuery;
import com.xataface.query.XFRecord;
import com.xataface.query.XFRowSet;

// ... redacted imports
/**
 * This file was generated by <a href="https://www.codenameone.com/">Codename One</a> for the purpose
 * of building native mobile applications using Java.
 */
public class MySQLContactsDemo {

    private Form current;
    private Resources theme;

    // redacted member declarations

    // Database Connection Properties
    private XFClient client;

    // ... redacted Style utility methods

    // Lifecycle Methods -------------------------------------------------------
    public void init(Object context) {

        // redacted boilerplate init stuff ...

        client = new XFClient("http://localhost/sakila/index.php"); (1)

    }

    public void start() {
        if(current != null){
            current.show();
            return;
        }
        Form hi = new Form("Contacts");
        hi.setLayout(new BorderLayout());

        hi.show();

        // Wrap loading of contacts in callSerially so that it happens after the form
        // is shown....
        Display.getInstance().callSerially(()->{
            loadContacts(rowset->{  (2)
                hi.addComponent(BorderLayout.CENTER, createContactsList(hi, rowset));
            });
        });
    }

    public void stop() {
        // redacted boilerplate ...
    }

    public void destroy() {
    }

    // Web Service Methods -----------------------------------------------------

    /**
     * Loads all of the contacts from the database asynchronously.  On complete
     * the callback will be called with the resulting rowset as a parameter, or
     * null if there was an error.
     * @param callback Callback to handle the received rowset.
     */
    private void loadContacts(SuccessCallback<XFRowSet> callback) {  (3)
        XFQuery q = new XFQuery("customer")
                .sort(XFQuery.SortOrder.ASCENDING, "last_name")
                .select("first_name", "last_name", "email")
                .findAll();
        client.find(q, callback);
    }

    /**
     * Convert a record from the "contact" table into a Contact object.
     * @param record A record from the "contact" table.
     * @return A Contact object
     */
    private static Contact createContact(XFRecord record) {  (4)
        Contact c = new Contact();
        c.setFirstName(record.getString("first_name"));
        c.setFamilyName(record.getString("last_name"));
        c.setPrimaryEmail(record.getString("email"));
        return c;
    }

    /**
     * Convert a rowset (from the contact table) into an array of Contact
     * objects
     * @param rowset A rowset from the contact table.
     * @return An array of Contact records.
     */
    private static Contact[] rowsetToContactsArray(XFRowSet rowset) {  (5)
        List<Contact> lst = new ArrayList<Contact>();
        for (XFRecord record : rowset) {
            lst.add(createContact(record));
        }
        return lst.toArray(new Contact[lst.size()]);
    }

    // View Factory Methods ----------------------------------------------------

    /**
     * Creates a list of contacts included in the specified rowset.
     * @param parentForm The parent form
     * @param rowset The rowset to encapsulate (from the "contact" table)
     * @return A container to be added to the form.
     */
    private Container createContactsList(Form parentForm, XFRowSet rowset) {
        Contact[] contacts = rowsetToContactsArray(rowset);

        // redacted image generation code ...

        // Create the parent container
        final Container contactsDemo = new Container(BoxLayout.y());
        contactsDemo.setScrollableY(true);

        // Add all of the rows to the container
        for(Contact c : contacts) {
            Container row = createContactRow(c, contactsDemo);
            if (row != null) {
                contactsDemo.add(row);
            }
        }
        contactsDemo.revalidate();
        finishedLoading = true;

        // XFClient won't load the whole set all at once because that would be a waste of
        // network traffic.  Default batch size is 30.  We use InfiniteScrollAdapter
        // to load more of the result set as the user scrolls down the list.

        // Store reference to the last loaded rowset.  We can use this
        // to obtain the "next" rowset, the next time the infinite scroll adapter
        // is fired.
        XFRowSet[] lastSet = new XFRowSet[]{rowset};
        InfiniteScrollAdapter.createInfiniteScroll(contactsDemo, () -> {

            // Check if we have have already loaded all of the records in the found set.
            if (lastSet[0].getFound() > lastSet[0].getLast()) {

                // Use the previous rowset to get the query to obtain the next result set.
                XFQuery nextQuery = lastSet[0].getQuery().getNextQuery();  (6)

                // Pass the query to the client to load the next result set asynchronously
                client.find(nextQuery, newResult -> {
                    if (newResult == null) {
                        return;
                    }
                    List<Component> toAdd = new ArrayList<Component>();
                    for (XFRecord row : newResult) {
                        Container cntRow = createContactRow(createContact(row), contactsDemo);
                        if (cntRow != null) {
                            toAdd.add(cntRow);
                        }
                    }
                    InfiniteScrollAdapter.addMoreComponents(contactsDemo, toAdd.toArray(new Component[toAdd.size()]), newResult.getLast() < newResult.getFound());

                    // Make sure to store this new result set as lastSet so that the next time
                    // we load records we continue where we left off
                    lastSet[0] = newResult;
                    contactsDemo.revalidate();
                });
            }
        });

        return contactsDemo;
    }

    /**
     * Creates a single row for the contact list that encapsulates the provided
     * contact.
     * @param c The contact to represent with this row.
     * @param parent The parent container to which the row is to be added.  This method doesn't actually add the
     * row to the parent, but it does need to reference it for some of the listeners that are added to the row.  The caller
     * should add the resulting row to the parent after calling this method.
     * @return A container encapsulating the row, or null if the contact didn't have a name.
     */
    private Container createContactRow(Contact c, Container parent) {
        // redacted... no Database-specific code here.
    }

}

// Perform async query on db to retrieve rowset
public void find(
     XFQuery query,
     SuccessCallback<XFRowSet> callback
);

// Save record asynchronously
public void save(
    XFRecord record,
    SuccessCallback<XFRecord> callback
);


// Delete record asynchronously
public void delete(
    XFRecord record,
    SuccessCallback<Boolean> callback
);

client = new XFClient("http://localhost/sakila/index.php");